Hi,
I believe that the title of this email thread was a typo, and should be
"Apache Flink - Question about checkpointing and re-run a job."
I assume this because the contents of the previous conversations seem to be
purely about Flink.
Otherwise, as far as I know, there doesn't seem to be any
Does Airflow has a Flink Operator? I am not seeing it? Can you please point
me?
On Mon, Nov 18, 2019 at 3:10 AM M Singh wrote:
> Thanks Congxian for your answer and reference. Mans
>
> On Sunday, November 17, 2019, 08:59:16 PM EST, Congxian Qiu <
> qcx978132...@gmail.com> wrote:
>
>
> Hi
>
Thanks Congxian for your answer and reference. Mans
On Sunday, November 17, 2019, 08:59:16 PM EST, Congxian Qiu
wrote:
HiYes, checkpoint data locates under jobid dir. you can try to restore from
the retained checkpoint[1][1]
Hi
Yes, checkpoint data locates under jobid dir. you can try to restore from
the retained checkpoint[1]
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/state/checkpoints.html#resuming-from-a-retained-checkpoint
Best,
Congxian
M Singh 于2019年11月18日周一 上午2:54写道：
> Folks -
Folks - Please let me know if you have any advice on this question. Thanks
On Saturday, November 16, 2019, 02:39:18 PM EST, M Singh
wrote:
Hi:
I have a Flink job and sometimes I need to cancel and re run it. From what I
understand the checkpoints for a job are saved under the job id
Hi:
I have a Flink job and sometimes I need to cancel and re run it. From what I
understand the checkpoints for a job are saved under the job id directory at
the checkpoint location. If I run the same job again, it will get a new job id
and the checkpoint saved from the previous run job (which
