You are viewing a plain text version of this content. The canonical link for it is here.

Posted to builds@flink.apache.org by GitBox <gi...@apache.org> on 2025/04/08 13:56:24 UTC

[GH] (flink-connector-kafka/v4.0): Workflow run "Flink Connector Kafka CI" failed!

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