[
https://issues.apache.org/jira/browse/FLINK-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aljoscha Krettek updated FLINK-9287:
------------------------------------
Description:
{{KafkaProducer011}} appears to be leaking {{kafka-producer-network-thread}}
threads. As far as I can tell it happens when it is not in EXACTLY_ONCE mode,
it seems that it creates a {{FlinkKafkaProducer}} but never closes it, even
when the {{FlinkKafkaProducer011}} itself is closed.
I observed this when running a local cluster and submitting and then cancelling
a job, a lot of kafka threads were left alive afterwards.
was:
{{KafkaProducer011}} appears to be leaking {{kafka-producer-network-thread
}}threads. As far as I can tell it happens when it is not in EXACTLY_ONCE
mode, it seems that it creates a {{FlinkKafkaProducer}} but never closes it,
even when the {{FlinkKafkaProducer011}} itself is closed.
I observed this when running a local cluster and submitting and then cancelling
a job, a lot of kafka threads were left alive afterwards.
> KafkaProducer011 seems to leak threads when not in exactly-once mode
> --------------------------------------------------------------------
>
> Key: FLINK-9287
> URL: https://issues.apache.org/jira/browse/FLINK-9287
> Project: Flink
> Issue Type: Bug
> Components: Kafka Connector
> Affects Versions: 1.4.2
> Reporter: Christopher Ng
> Priority: Minor
>
> {{KafkaProducer011}} appears to be leaking {{kafka-producer-network-thread}}
> threads. As far as I can tell it happens when it is not in EXACTLY_ONCE
> mode, it seems that it creates a {{FlinkKafkaProducer}} but never closes it,
> even when the {{FlinkKafkaProducer011}} itself is closed.
> I observed this when running a local cluster and submitting and then
> cancelling a job, a lot of kafka threads were left alive afterwards.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
