The GitHub Actions job "Flink Connector Kafka CI" on flink-connector-kafka.git/v4.0 has failed. Run started by GitHub user AHeise (triggered by AHeise).
Head commit for run: 1fec86e79db4049aa782c674ff6fae569879efb7 / Arvid Heise <ar...@apache.org> [FLINK-37622] Fix KafkaSink in BATCH Since BATCH doesn't call snapshotState(), we never rotate the producer in batch mode. Hence, on closing the producer in the write failover region, we also abort the ongoing transaction. The committer in the next region is then failing. This commit generalizes the client side transaction state machine and adds a new state for precommitted. Then the writer must abort only those transactions that are not precommitted. Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/14334279134 With regards, GitHub Actions via GitBox
