DTStack / DTStack/chunjun

local模式下再次提交任务,checkpoint有时生效有时不生效

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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.