当前位置： 首页 >> Flink >> Flink实战-部署上线

---

Flink实战-部署上线

2020-10-08 17:06:49 星期四  阅读：2619

---

####开启Flink集群 ``` $ su - flink $ cd /usr/local/flink/flink-1.7.2 $ bin/yarn-session.sh -n 4 -s 4 -jm 1000 -tm 1000 -nm build_flink -d ``` 启动成功后控制台如下所示 ``` 2020-03-15 14:50:46,768 INFO org.apache.flink.yarn.cli.FlinkYarnSessionCli - The Flink YARN client has been started in detached mode. In order to stop Flink on YARN, use the following command or a YARN web interface to stop it: yarn application -kill application_1584148657859_0165 ``` #### 项目打包 注意，需要修改pom.xml文件的mainClass属性，因为一个项目里会有很多main方法，你的jar包是为哪个类打的，需要在这里指定。 `<mainClass>cn.libins.MyStreamWordCount</mainClass>` 设置完后，在终端（项目的根目录下）运行mvn命令。 `$ mvn clean package -DskipTests` 运行完后，直接上jar包集群执行。 ``` $ cd /usr/local/flink/flink-1.7.2 $ bin/flink run -m yarn-cluster /home/flink/my-kafka-flink-project-1.0-SNAPSHOT.jar ``` 保证Kafka的生产者在一直发送消息。浏览器打开Flink的web监控页面查看计算情况：http://192.168.1.101:8081 Hue查询验证 `SELECT * FROM word_count_realtime ORDER BY id DESC;`