The GitHub Actions job "CI" on flink-connector-kafka.git has failed. Run started by GitHub user MartijnVisser (triggered by MartijnVisser).
Head commit for run: b316d8ce25cc63bc6cdb858831e8566164a16b81 / 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. (cherry picked from commit b0f15f279915a3862d353c9d2726a52741c248ba) Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/6479145781 With regards, GitHub Actions via GitBox
