You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Chris Slotterback (JIRA)" <ji...@apache.org> on 2019/05/08 14:57:00 UTC
[jira] [Created] (FLINK-12448) FlinkKafkaProducer late closure
after class loader
Chris Slotterback created FLINK-12448:
-----------------------------------------
Summary: FlinkKafkaProducer late closure after class loader
Key: FLINK-12448
URL: https://issues.apache.org/jira/browse/FLINK-12448
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.7.2
Reporter: Chris Slotterback
During job failure/restart, FlinkKafkaProducer configured with Semantic.EXACTLY_ONCE fails to disconnect properly do to a NoClassDefFoundError:
{noformat}
java.lang.NoClassDefFoundError: org/apache/kafka/clients/NetworkClient$1
at org.apache.kafka.clients.NetworkClient.processDisconnection(NetworkClient.java:658)
at org.apache.kafka.clients.NetworkClient.handleDisconnections(NetworkClient.java:805)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:520)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:226)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:163)
at java.lang.Thread.run(Thread.java:748){noformat}
This begins a restart loop where the job never recovers properly. This is reproducible only with EXACTLY_ONCE semantic, AT_LEAST_ONCE properly disconnects and restarts without error.
This issue is described in FLINK-10455, but has been since marked as Fixed, but still reproducible.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)