The GitHub Actions job "Flink Connector Kafka CI" on 
flink-connector-kafka.git/FLINK-38453-enum-state has failed.
Run started by GitHub user AHeise (triggered by AHeise).

Head commit for run:
10fb75e2b8a2c2944b7a5e673f9c6e6825c7ea60 / Arvid Heise <[email protected]>
[FLINK-38681] Revise threading model in enumerator

FLINK-38453 broke the threading model of KafkaEnumerator by accessing some of 
the data structures from the worker thread without synchronization. The 
migration path also triggers NPE.

This commit partially reverts some changes regarding multi-threading while 
making migration more robust.

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

With regards,
GitHub Actions via GitBox

Reply via email to