session模式

1
2
3
4
5
6
7
#启动
./bin/yarn-session.sh --detached
#重启
./bin/yarn-session.sh -id application_

#停止
echo "stop" | ./bin/yarn-session.sh -id application_

任务管理

1
2
3
4
5
6
7
8
9
10
11
12
13
#任务监控
 ./bin/flink list
 
#创建savepoint
./bin/flink savepoint  $JOB_ID  hdfs://hadoop-01:9000/flink_savepoint/savepoint-e24855-64847000b217
     
     
#优雅停止任务
./bin/flink stop  $JOB_ID --savepointPath hdfs://hadoop-01:9000/flink_savepoint/savepoint-e24855-64847000b217 
 7b5f2bb1dd2a445c3f4909c31306028c
#启动
flink-cdc/bin/flink-cdc.sh flink-cdc/mysql-source/hpcang_order_center.yml -s hdfs://hadoop-01:9000/flink_savepoint/savepoint-e24855-64847000b217