local模式下再次提交任务,checkpoint有时生效有时不生效
Open
bug
- Dominant language
- Java
- Stars
- 4.1k
- Forks
- 1.7k
- PR merge metrics
- No merged PRs in 30d
Description
local模式下,再次提交任务,需要指定上次成功保存的最近一次checkpoint路径,有时生效有时不生效,请问是什么问题?:
bin/flinkx \
-mode yarn \
-job /home/flinkx-1.8_release/mysql.json \
-pluginRoot /home/flinkx-1.8_release/plugins \
-flinkconf /home/flink-1.8.1/conf \
-yarnconf /data/hadoop-2.7.7/etc/hadoop \
-confProp {\"flink.checkpoint.interval\":30000} \
-queue a \
-s hdfs://ns/flink180/checkpoints/metadata/10c4c972de4240c717e482d6c1b4d7bf/chk-1
Contributor guide
Assessment
This issue has not been assessed yet.