Github user tzulitai commented on the issue:
https://github.com/apache/flink/pull/2789
> Also, both the fetcher and the KafkaConsumerThread are written to
encapsulate all necessary logic self contained. That means they do not rely on
each other to call handover.close() in any situation - that makes the design
more robust.
I think that makes sense. My suggestions will definitely make the fetcher
thread rely on the KafkaConsumerThread to do correct calls.
Agree to keep it as is :)
---
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.
---
