flink 保存点测试

flink 保存点测试

首先需要去flink ui上找到自己的job id，ui端口默认是8081

执行命令flink cancel --withSavepoint /flinkCDC/save eaf2a70b59827948a1cef7ecc9723206

接着从保存点启动

flink run -s /flinkCDC/save/savepoint-eaf2a7-a8d008adda3a -c test1 /app/myjar/test-1.0-SNAPSHOT-jar-with-dependencies.jar

去ui查看一些信息