DTStack / DTStack/flinkx

flinkx1.12.7 在恢复checkpoint没起效

Open
#2 0 comments 0 reactions 0 assignees View on GitHub
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.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.