You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Christopher Ng (JIRA)" <ji...@apache.org> on 2018/05/02 10:42:00 UTC
[jira] [Created] (FLINK-9287) KafkaProducer011 seems to leak
threads when not in exactly-once mode
Christopher Ng created FLINK-9287:
-------------------------------------
Summary: 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
{{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)