The GitHub Actions job "Flink Connector Kafka CI" on 
flink-connector-kafka.git/FLINK-39728-pause-resume-race has succeeded.
Run started by GitHub user jnh5y (triggered by jnh5y).

Head commit for run:
5a53da774d83ce6ddccdf04ebbdbf015c58e9d40 / Jim Hughes <[email protected]>
[FLINK-39728] Fix pauseOrResumeSplits race with unassigned partitions

Filter against consumer.assignment() before calling pause()/resume()
to prevent IllegalStateException when a partition is concurrently
unassigned by fetch() or removeEmptySplits().

Generated-by: Claude Opus 4.6 (Anthropic)

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

With regards,
GitHub Actions via GitBox

Reply via email to