The GitHub Actions job "Flink Connector Kafka CI" on 
flink-connector-kafka.git/FLINK-34554-fix-transaction-ids has succeeded.
Run started by GitHub user AHeise (triggered by AHeise).

Head commit for run:
aa433bc88d5d715c3481c5e1ae489a7794912111 / 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.

Report URL: 
https://github.com/apache/flink-connector-kafka/actions/runs/14179774427

With regards,
GitHub Actions via GitBox

Reply via email to