Commits on Oct 10, 2023

1. [FLINK-33231] [source] Properly evict offsetsToCommit cache on checkp… …

   …oint complete if no offsets exist
   
   Prior to this fix, if the offsets to commit for a given checkpoint is empty,
   which can be the case if no starting offsets were retrieved from Kafka yet,
   then on checkpoint completion the cache is not properly evicted up to the
   given checkpoint.
   
   This change fixes this such that in notifyOnCheckpointComplete, we shortcut
   the method execution to not need to try to commit the offsets since its
   empty anyways, and always remember to evict the cache up to the completed
   checkpoint.

   

   tzulitai committed Oct 10, 2023
   Configuration menu

   • View commit details
   • Copy full SHA for 1b4c978
   • Browse repository at this point

   Copy the full SHA

   1b4c978 View commit details

   Browse the repository at this point in the history