[
https://issues.apache.org/jira/browse/FLINK-20194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin reassigned FLINK-20194:
------------------------------------
Assignee: Jiangjie Qin
> KafkaSourceFetcherManager.commitOffsets() should handle the case when there
> is no split fetcher.
> ------------------------------------------------------------------------------------------------
>
> Key: FLINK-20194
> URL: https://issues.apache.org/jira/browse/FLINK-20194
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Kafka
> Reporter: Jiangjie Qin
> Assignee: Jiangjie Qin
> Priority: Critical
> Fix For: 1.12.0
>
>
> The {{KafkaSourceFetcherManager.commitOffsets()}} may throw NPE when there is
> no split fetcher. Given that such cases should usually be rare and only
> happens when the source is shutting down or just started. We can create a new
> {{KafkaPartitionSplitReader}} to commit offset and close it immediately. The
> main thread maybe blocked for some time, but given that there is no event to
> process at that point, there should be no performance concerns.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
