Thank you for the clarification Yun, it helps. *-- Best wishes* *Kai*
On Mon, Apr 5, 2021 at 12:03 PM Yun Gao <yungao...@aliyun.com> wrote: > Hi Kai, > > Yes, you are basically right, one minor point is that the start time is > taken as the time that the checkpoint get intiated in the JM side. > > Best, > Yun > > > ------------------Original Mail ------------------ > *Sender:*Kai Fu <zzfu...@gmail.com> > *Send Date:*Mon Apr 5 09:31:58 2021 > *Recipients:*user <user@flink.apache.org> > *Subject:*Re: Meaning of checkpointStartDelayNanos > >> 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* >> > -- *Best regards,* *- Kai*
