flinkx1.12.7 在恢复checkpoint没起效
- Dominant language
- No language data
- Stars
- 55
- Forks
- 13
- PR merge metrics
- No merged PRs in 30d
Description
example: execute the command as follows:
1. savepoint 使用
./bin/flinkx -mode standalone -jobType sql -flinkxDistDir flinkx-dist -job flinkx-examples/sql/develp/cp.sql -flinkLibDir ../flink-1.12.7/lib -flinkConfDir ../flink-1.12.7/conf -confProp "{\"sql.checkpoint.mode\":\"EXACTLY_ONCE\",\"execution.checkpointing.interval\":\"6000\"}" -s hdfs://dswhhadoop-3:8020/warehouse/tablespace/managed/checkpoint/0aa6ad6d5daafd265bebb8de6c2d8bd4
结果报错! 显示没有-s这个参数选项,无法恢复savepoint
2. 另外一种方式
./bin/flinkx -mode standalone -jobType sql -flinkxDistDir flinkx-dist -job flinkx-examples/sql/develp/cp.sql -flinkLibDir ../flink-1.12.7/lib -flinkConfDir ../flink-1.12.7/conf -confProp "{\"sql.checkpoint.mode\":\"EXACTLY_ONCE\",\"execution.checkpointing.interval\":\"6000\",\"flink.checkpoint.interval\":8000,\"sql.checkpoint.timeout\":\"200000\",\"state.backend\":\"FILESYSTEM\",\"state.savepoints.dir\":\"hdfs://dswhhadoop-3:8020/warehouse/tablespace/managed/savepoint\",\"state.checkpoints.dir\":\"hdfs://dswhhadoop-3:8020/warehouse/tablespace/managed/checkpoint\"}"
通过在配置-confProp中 配置"state.savepoints.dir 也没有起作用 ,bi站官方视频上面是之前的版本,支持-s ,1.12版不支持了,
不知道如何使用flinkx 自带的任务挂了,重启实现断点续传功能?
Contributor guide
No contributing guide indexed for this repository
Assessment
This issue has not been assessed yet.