大数据之Flink(3) | Flink部署

野性酷女 2022-12-15 14:15 176阅读 0赞

### Standalone模式 ###

*  一.Standalone模式
 *   *  安装
     *  提交任务(手动代码或者网页)

# 一.Standalone模式 #

## 安装 ##

解压缩 flink-1.10.0-bin-scala\_2.11.tgz，进入conf目录中。  
1） 修改 flink/conf/flink-conf.yaml 文件：

jobmanager.rpc.address: hadoop12

2）修改 /conf/slaves文件：

hadoop13
    hadoop14

3）分发给另外两台机子：

xsync flink-1.10.0

4）启动：

bin/start-cluster.sh

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ2NTQ4ODU1_size_16_color_FFFFFF_t_70_pic_center]  
访问http://hadoop12:8081可以对flink集群和任务进行监控管理。

## 提交任务(手动代码或者网页) ##

**网页版**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ2NTQ4ODU1_size_16_color_FFFFFF_t_70_pic_center 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ2NTQ4ODU1_size_16_color_FFFFFF_t_70_pic_center 2]  
**手动代码**  
执行程序

[root@hadoop12 flink-1.10.0]# ./bin/flink run -c com.donglin.wc.StreamWordCount -p 1 Flink-Learning-1.0-SNAPSHOT-jar-with-dependencies.jar --host hadoop12 --port 9999
    Job has been submitted with JobID 0d6526c4214f890663d13f6265bf2943

关闭程序

[root@hadoop12 flink-1.10.0]# ./bin/flink cancel 0d6526c4214f890663d13f6265bf2943

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ2NTQ4ODU1_size_16_color_FFFFFF_t_70_pic_center]: /images/20221123/87698e7ad57a4f54bb9673cb3a6bb90c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ2NTQ4ODU1_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221123/b97229c90bc045b9847f862d9e4bf9d4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQ2NTQ4ODU1_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221123/3a3a5d3fa1b94125a22239eb25a4eb4c.png