Hi Kai,

Under unaligned checkpoint settings, there are still alignment process. Although
the task could snapshot the state of the operators on received the first 
barrier and
emit barriers to the following tasks, it still need to wait till all the 
barriers to be received
before finalize the checkpoint, and during this process, it need to snapshot 
the buffers
that are skipped by the barrier, and the final snapshot would compose of both 
the operator
snapshots and the snapshots of the skipped buffers. 

Therefore, the checkpointAlignmentTime metric still exists.

Best,
Yun



 ------------------Original Mail ------------------
Sender:Kai Fu <zzfu...@gmail.com>
Send Date:Mon Apr 5 09:18:39 2021
Recipients:user <user@flink.apache.org>
Subject:Questions about checkpointAlignmentTime in unaligned checkpoint

Hi team,

I'm observing the metrics reporter still emits checkpointAlignmentTime metric 
in the unaligned checkpoint setting as shown in the figure below. Is it a 
meaningful in unaligned checkpoint, since I suppose the alignment operation 
only happens in aligned checkpoint.  



-- 
Best regards,- Kai

Reply via email to