[GitHub] flink pull request #5661: [FLINK-8896][kafka08] fix Kafka08Fetcher trying to...

2018-03-09 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/5661 ---

[GitHub] flink pull request #5661: [FLINK-8896][kafka08] fix Kafka08Fetcher trying to...

2018-03-08 Thread NicoK
GitHub user NicoK opened a pull request: https://github.com/apache/flink/pull/5661 [FLINK-8896][kafka08] fix Kafka08Fetcher trying to look up topic "n/a" on partiton "-1" ## What is the purpose of the change `Kafka08Fetcher` uses a `MARKER` to make sure the main thread