flinkx
flinkx copied to clipboard
flinkx1.12.7 在恢复checkpoint没起效
example: execute the command as follows:
- 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
- 另外一种方式 ./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 自带的任务挂了,重启实现断点续传功能?