pcalpha created FLINK-21040:
-------------------------------
Summary: The exception of "Unknown consumerTag" may throw when
RMQSource close() is called.
Key: FLINK-21040
URL: https://issues.apache.org/jira/browse/FLINK-21040
Project: Flink
Issue Type: Bug
Components: Connectors/ RabbitMQ
Affects Versions: 1.12.1, 1.11.3, 1.11.2, 1.11.1, 1.12.0, 1.10.2, 1.11.0,
1.10.1, 1.10.0, 1.9.3, 1.9.2, 1.9.1, 1.9.0, 1.8.3, 1.8.2, 1.8.1, 1.8.0, 1.7.2,
1.6.4, 1.6.3
Reporter: pcalpha
The log is below
2020-10-27 21:00:57 [ Source: rabbitmqSource -> Flat Map (1/1):292311427 ] - [
ERROR ] Error during disposal of stream operator.2020-10-27 21:00:57 [
Source: rabbitmqSource -> Flat Map (1/1):292311427 ] - [ ERROR ] Error during
disposal of stream operator.java.lang.RuntimeException: Error while cancelling
RMQ consumer on xxxxxxxQueueName at 10.xx.xx.102 at
org.apache.flink.streaming.connectors.rabbitmq.RMQSource.close(RMQSource.java:196)
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:703)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUpInvoke(StreamTask.java:635)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:542)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721) at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:546) at
java.base/java.lang.Thread.run(Thread.java:834)Caused by: java.io.IOException:
Unknown consumerTag at
com.rabbitmq.client.impl.ChannelN.basicCancel(ChannelN.java:1285) at
com.rabbitmq.client.impl.recovery.AutorecoveringChannel.basicCancel(AutorecoveringChannel.java:482)
at
org.apache.flink.streaming.connectors.rabbitmq.RMQSource.close(RMQSource.java:192)
... 8 more
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
