The GitHub Actions job "Flink Connector Kafka CI" on flink-connector-kafka.git/FLINK-34554-fix-transaction-ids has failed. Run started by GitHub user AHeise (triggered by AHeise).
Head commit for run: 7b8498c275294ac5aeffc5e2f96daae14c615002 / Arvid Heise <ar...@apache.org> Fix ownership model The previous approach assumed that state is restributed by modulo and mapped the ownership model to it. However, it's actually redistributed in a more range partition oriented way where a scale down from 4->2 results in subtask 0 getting the state assigned from old subtask 0 and 1. This commit introduces a strong ownership model based on writerStates that provide the subtask with a number of owned subtaskIds based on the checkpointed max parallelism of the job. Report URL: https://github.com/apache/flink-connector-kafka/actions/runs/14239074391 With regards, GitHub Actions via GitBox
