Subject: Re: Pravega connector cannot recover from the checkpoint due to
"Failure to finalize checkpoint"
[EXTERNAL EMAIL]
Hi Brian,
AFAIK, Arvid and Piotr (both in CC) have been working on the threading model of
the checkpoint coordinator.
Maybe they can help with this question.
Be
ards,
>
> Brian
>
>
>
> *From:* Zhou, Brian
> *Sent:* Wednesday, July 15, 2020 18:26
> *To:* 'user@flink.apache.org'
> *Subject:* Pravega connector cannot recover from the checkpoint due to
> "Failure to finalize checkpoint"
>
>
>
> Hi community,
Anyone can help us on this issue?
Best Regards,
Brian
From: Zhou, Brian
Sent: Wednesday, July 15, 2020 18:26
To: 'user@flink.apache.org'
Subject: Pravega connector cannot recover from the checkpoint due to "Failure
to finalize checkpoint"
Hi community,
To give so
Hi community,
To give some background, https://github.com/pravega/flink-connectors is a
Pravega connector for Flink. The ReaderCheckpointHook[1] class uses the Flink
`MasterTriggerRestoreHook` interface to trigger the Pravega checkpoint during
Flink checkpoints to make sure the data recovery. We
