[ https://issues.apache.org/jira/browse/FLINK-9287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Piotr Nowojski updated FLINK-9287: ---------------------------------- Priority: Blocker (was: Minor) > 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.5.0, 1.4.2 > Reporter: Christopher Ng > Priority: Blocker > > {{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)