You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by Morgan Geldenhuys <mo...@tu-berlin.de> on 2020/02/07 11:12:47 UTC
Question: Modifying Checkpoint Interval at runtime
I am working with the Flink at the moment and am interested in modifying
the codebase so that the checkpoint interval can be changed at runtime,
(e.g. if it was set to kickoff the distributed snapshot process every 10
seconds, and then I wanted to change it to every 15 seconds instead
without restarting). I was wondering, in your professional opinion, is
this possible? Of course I am not expecting this to be a simple
implementation, however, what considerations would I need to take into
account and which parts of the codebase would this modification involve.
Re: Question: Modifying Checkpoint Interval at runtime
Posted by Congxian Qiu <qc...@gmail.com>.
In current Flink, the checkpoint interval can not be modified after job
started, If you want to change the code to implement this feature, maybe
you can try to see the logic in CheckpointCoordinator, and the usage of
function checkMinPauseBetweenCheckpoints[1] and
scheduleTriggerWithDelay()[2]
[1]
https://github.com/apache/flink/blob/19689cb8ddb7cdc57a99d02217e67880c5e938a5/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java#L1463
[2]
https://github.com/apache/flink/blob/19689cb8ddb7cdc57a99d02217e67880c5e938a5/flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java#L1485
Best,
Congxian
Morgan Geldenhuys <mo...@tu-berlin.de> 于2020年2月7日周五 下午7:12写道:
> I am working with the Flink at the moment and am interested in modifying
> the codebase so that the checkpoint interval can be changed at runtime,
> (e.g. if it was set to kickoff the distributed snapshot process every 10
> seconds, and then I wanted to change it to every 15 seconds instead
> without restarting). I was wondering, in your professional opinion, is
> this possible? Of course I am not expecting this to be a simple
> implementation, however, what considerations would I need to take into
> account and which parts of the codebase would this modification involve.
>