The GitHub Actions job "Weekly Flink Connector Kafka CI" on 
flink-connector-kafka.git/main has failed.
Run started by GitHub user MartijnVisser (triggered by MartijnVisser).

Head commit for run:
eb8ff700b2390d5bc3a8c67fcdb3f3ad93824e24 / 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/28724845081

With regards,
GitHub Actions via GitBox

Reply via email to