AHeise opened a new pull request, #195: URL: https://github.com/apache/flink-connector-kafka/pull/195
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. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
