session模式

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

任务管理

1
2
3
4
5
6
7
8
9
10
11
12
#任务监控
 ./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 
 
#启动
flink-cdc/bin/flink-cdc.sh flink-cdc/mysql-source/hpcang_order_center.yml -s hdfs://hadoop-01:9000/flink_savepoint/savepoint-e24855-64847000b217