NicoK commented on pull request #14635:
URL: https://github.com/apache/flink/pull/14635#issuecomment-765514464


   So, as soon as we are through the sync phase, we will get stats (if the CP 
is aborted during the sync phase, that won't interrupt the sync part anyway and 
will wait for it to complete). If we didn't reach the sync phase yet, the 
timeout could be because of slowly moving barriers (no barrier was received 
yet) or slow alignment (some barriers received but not all). These could be 
derived from looking at backpressure or data skew or starting times of other 
subtasks or timings from previous subtasks.
   
   I think, the current state is a good step forward and the stats look good 
:+1: 


----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to