Re: Re: Meaning of checkpointStartDelayNanos
Thank you for the clarification Yun, it helps. *-- Best wishes* *Kai* On Mon, Apr 5, 2021 at 12:03 PM Yun Gao 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 > *Send Date:*Mon Apr 5 09:31:58 2021 > *Recipients:*user > *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 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*
Re: Re: Meaning of checkpointStartDelayNanos
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 Send Date:Mon Apr 5 09:31:58 2021 Recipients:user Subject:Re: Meaning of checkpointStartDelayNanos I found its meaning in the code. 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 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 does not help too much. Can someone help to explain it more clearly? -- Best regards,- Kai -- Best regards,- Kai
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 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*
Meaning of checkpointStartDelayNanos
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*
