The GitHub Actions job "CI" on flink-connector-kafka.git has failed. Run started by GitHub user tzulitai (triggered by tzulitai).
Head commit for run: 3654f89b72f0b18fcc2f4f43795b19850f80e2b9 / Tzu-Li (Gordon) Tai <[email protected]> [FLINK-33231] [source] Properly evict offsetsToCommit cache on checkpoint 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. Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/6473886462 With regards, GitHub Actions via GitBox
