Thanks for the prompt reply Stefan!
On Fri, Sep 8, 2017 at 9:25 AM, Stefan Richter
wrote:
> Hi,
>
> the method is only called after the checkpoint completed on the job
> manager. At this point _all_ work for the checkpoint is done, so doing work
> in this callback does not add any overhead to th
Hi,
the method is only called after the checkpoint completed on the job manager. At
this point _all_ work for the checkpoint is done, so doing work in this
callback does not add any overhead to the checkpoint.
Best,
Stefan
> Am 08.09.2017 um 10:20 schrieb Martin Eden :
>
> Hi all,
>
> I have
Hi all,
I have a Flink 1.3.1 job with a source that implements
CheckpointingFunction.
As I understand it, the notifyCheckpointComplete callback is called when
all the downstream operators in the DAG successfully finished their
checkpoints.
Since I am doing some work in this method, I would like
