I found its meaning in the code <https://github.com/apache/flink/blob/99c2a415e9eeefafacf70762b6f54070f7911ceb/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L887-L892>. It means the delay of checkpoint action when the checkpoint barrier comes to the current operator since it's intiated in the source.
On Mon, Apr 5, 2021 at 9:21 AM Kai Fu <zzfu...@gmail.com> wrote: > Hi team, > > I'm a little confused by the meaning of *checkpointStartDelayNanos*, I do > not understand what time it exactly means, but it seems it's a quite > important indicator for checkpoint/backpresure. The explanation of it on > metrics > page > <https://ci.apache.org/projects/flink/flink-docs-stable/ops/metrics.html> does > not help too much. Can someone help to explain it more clearly? > > -- > *Best regards,* > *- Kai* > -- *Best regards,* *- Kai*
