启动
两种启动、停止方法:
- 一个命令启动、停止集群
- 单独启动、停止
jobmanager、taskmanager
启动集群
登录 hadoop1,进入 /program/flink-1.12.5/bin 目录:
cd /program/flink-1.12.5/bin
执行下面命令:
./start-cluster.sh
执行结果如下:
Starting cluster.
Starting standalonesession daemon on host hadoop1.
Starting taskexecutor daemon on host hadoop2.
Starting taskexecutor daemon on host hadoop3.
单独启动
进入 /program/flink-1.12.5/bin 目录:
cd /program/flink-1.12.5/bin
启动 jobmanager
jobmanager.sh start
启动 taskmanager
taskmanager.sh start
停止集群
./stop-cluster.sh
单独停止
停止 jobmanager
jobmanager.sh stop
或者
jobmanager.sh stop-all
停止 taskmanager
taskmanager.sh stop
或者
taskmanager.sh stop-all
查看是否启动
hadoop1
登录 hadoop1 执行下面命令:
jps
看到下面进程说明启动成功:
114358 StandaloneSessionClusterEntrypoint
61644 TaskManagerRunner
hadoop2
登录 hadoop2 执行下面命令:
jps
看到下面进程说明启动 jobmanager.sh 成功:
118642 TaskManagerRunner