[
https://issues.apache.org/jira/browse/FLINK-24263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414010#comment-17414010
]
Yufan Sheng commented on FLINK-24263:
-------------------------------------
[~xtsong] Duplicated by https://issues.apache.org/jira/browse/FLINK-24206
> PulsarSourceITCase.testMultipleSplits fails due to "Consumer not found"
> -----------------------------------------------------------------------
>
> Key: FLINK-24263
> URL: https://issues.apache.org/jira/browse/FLINK-24263
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.14.0
> Reporter: Xintong Song
> Priority: Major
> Labels: test-stability
> Fix For: 1.14.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=23958&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461&l=24936
> {code}
> Sep 13 00:00:49 Caused by:
> org.apache.pulsar.client.api.PulsarClientException$BrokerMetadataException:
> Consumer not found
> Sep 13 00:00:49 at
> org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:987)
> Sep 13 00:00:49 at
> org.apache.pulsar.client.impl.PulsarClientImpl.close(PulsarClientImpl.java:658)
> Sep 13 00:00:49 at
> org.apache.flink.connector.pulsar.source.reader.source.PulsarSourceReaderBase.close(PulsarSourceReaderBase.java:83)
> Sep 13 00:00:49 at
> org.apache.flink.connector.pulsar.source.reader.source.PulsarOrderedSourceReader.close(PulsarOrderedSourceReader.java:170)
> Sep 13 00:00:49 at
> org.apache.flink.streaming.api.operators.SourceOperator.close(SourceOperator.java:324)
> Sep 13 00:00:49 at
> org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141)
> Sep 13 00:00:49 at
> org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127)
> Sep 13 00:00:49 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1030)
> Sep 13 00:00:49 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:874)
> Sep 13 00:00:49 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:762)
> Sep 13 00:00:49 at
> org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
> Sep 13 00:00:49 at
> org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
> Sep 13 00:00:49 at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
> Sep 13 00:00:49 at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
> Sep 13 00:00:49 at java.lang.Thread.run(Thread.java:748){code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
