flink搭建
- 作者: 丁杨55306969
- 来源: 51数据库
- 2020-09-24
2.解压
上传至五个节点的相同目录,执行如下命令解压:
tar xzf flink-1.3.1-bin-hadoop26-scala_2.11.tgz
3.配置master节点
选择一个 master节点(JobManager)然后在conf/flink-conf.yaml中设置jobmanager.rpc.address 配置项为该节点的IP 或者主机名。确保所有节点有有一样的jobmanager.rpc.address 配置。
4.配置slaves
将所有的 worker 节点 (TaskManager)的IP 或者主机名(一行一个)填入conf/slaves 文件中。
5.启动flink集群
bin/start-cluster.sh
6.注意
我是来看评论的
上传至五个节点的相同目录,执行如下命令解压:
tar xzf flink-1.3.1-bin-hadoop26-scala_2.11.tgz
3.配置master节点
选择一个 master节点(JobManager)然后在conf/flink-conf.yaml中设置jobmanager.rpc.address 配置项为该节点的IP 或者主机名。确保所有节点有有一样的jobmanager.rpc.address 配置。
4.配置slaves
将所有的 worker 节点 (TaskManager)的IP 或者主机名(一行一个)填入conf/slaves 文件中。
5.启动flink集群
bin/start-cluster.sh
6.注意
我是来看评论的
推荐阅读