Github user zjureel commented on the issue:
https://github.com/apache/flink/pull/3766
@tzulitai Thank you for your replay.
For 1, the `ExecutorService` is used to control timeout of fetching kafka
partitions. When fetch kafka partitions, a `Future` will be created and
executed in `ExecutorService`, which will wait for some mills and throw
exception for timeout.
For 2, I had deprecated constructors of 08 / 09/ 010 whose parameter is
`KafkaPartitioner` and add the same constructors with parameter
`FlinkKafkaPartitioner`.
I find the codes in master of apache/flink were modified relative large
some days ago, and I try rebase these modification soon. I think you can review
these issues after that, thank you.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
