[
https://issues.apache.org/jira/browse/FLINK-9390?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16479465#comment-16479465
]
Stephan Ewen commented on FLINK-9390:
-------------------------------------
When closing due to cancellation, the thread will be interrupted (have its
interruption flag set).
That's why we should quasi always see this exception.
We can try and clear the interruption flag around the closing, or
regognize/ignore the interrupted exception to improve this.
> Shutdown of KafkaProducer causes confusing log message
> ------------------------------------------------------
>
> Key: FLINK-9390
> URL: https://issues.apache.org/jira/browse/FLINK-9390
> Project: Flink
> Issue Type: Bug
> Components: Kafka Connector
> Affects Versions: 1.5.0, 1.6.0
> Reporter: Stefan Richter
> Priority: Minor
>
> I found some logged exceptions in a user log that occurred during shutdown in
> the context of the Kafka Producer. Those exceptions are most certainly not a
> real problem, but can be confusing to users, so maybe we can get rid of them.
> {code}
> 2018-05-16 08:52:16,526 DEBUG
> org.apache.flink.streaming.api.operators.async.Emitter - Emitter thread got
> interrupted, shutting down.
> 2018-05-16 08:52:16,527 ERROR
> org.apache.flink.streaming.runtime.tasks.StreamTask - Error during disposal
> of stream operator.
> org.apache.kafka.common.KafkaException: Failed to close kafka producer
> at
> org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:734)
> at
> org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:682)
> at
> org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:661)
> at
> org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase.close(FlinkKafkaProducerBase.java:319)
> at
> org.apache.flink.api.common.functions.util.FunctionUtils.closeFunction(FunctionUtils.java:43)
> at
> org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.dispose(AbstractUdfStreamOperator.java:117)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.disposeAllOperators(StreamTask.java:479)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:384)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:703)
> at java.lang.Thread.run(Thread.java:748)
> Caused by: java.lang.InterruptedException
> at java.lang.Object.wait(Native Method)
> at java.lang.Thread.join(Thread.java:1260)
> at
> org.apache.kafka.clients.producer.KafkaProducer.close(KafkaProducer.java:703)
> ... 9 more
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
