[GitHub] flink pull request #5329: [FLINK-8409] [kafka] Fix potential NPE in KafkaCon...

2018-02-06 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5329 ---

[GitHub] flink pull request #5329: [FLINK-8409] [kafka] Fix potential NPE in KafkaCon...

2018-01-21 Thread tzulitai
GitHub user tzulitai opened a pull request: https://github.com/apache/flink/pull/5329 [FLINK-8409] [kafka] Fix potential NPE in KafkaConsumerThread ## What is the purpose of the change This PR fixes a race condition that may lead to a NPE in the async callbacks for Kafka