前言
官网
https://nightlies.apache.org/flink/flink-docs-release-1.15/zh/docs/ops/state/savepoints/
测试任务
先起一个测试任务,就用之前文章中的 cdc_mysql2mysql1
bin/sql-client.sh -f sql/cdc_mysql2mysql.sql
使用 YARN 触发 Savepoint
根据官方文档:1
bin/flink savepoint :jobId [:targetDirectory] -yid :yarnAppId
那么命令应该为1
bin/flink savepoint 24f61a106d31205a122b66e45b2984e7 /savepoint/cdc_mysql2mysql -yid application_1750755047138_0076