Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Duplicate
-
1.14.0
-
None
-
None
Description
Aug 27 09:41:42 Caused by: org.apache.pulsar.client.api.PulsarClientException$BrokerMetadataException: Consumer not found Aug 27 09:41:42 at org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:987) Aug 27 09:41:42 at org.apache.pulsar.client.impl.PulsarClientImpl.close(PulsarClientImpl.java:658) Aug 27 09:41:42 at org.apache.flink.connector.pulsar.source.reader.source.PulsarSourceReaderBase.close(PulsarSourceReaderBase.java:83) Aug 27 09:41:42 at org.apache.flink.connector.pulsar.source.reader.source.PulsarOrderedSourceReader.close(PulsarOrderedSourceReader.java:170) Aug 27 09:41:42 at org.apache.flink.streaming.api.operators.SourceOperator.close(SourceOperator.java:308) Aug 27 09:41:42 at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.close(StreamOperatorWrapper.java:141) Aug 27 09:41:42 at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.closeAllOperators(RegularOperatorChain.java:127) Aug 27 09:41:42 at org.apache.flink.streaming.runtime.tasks.StreamTask.closeAllOperators(StreamTask.java:1015) Aug 27 09:41:42 at org.apache.flink.streaming.runtime.tasks.StreamTask.afterInvoke(StreamTask.java:859) Aug 27 09:41:42 at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:747) Aug 27 09:41:42 at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958) Aug 27 09:41:42 at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937) Aug 27 09:41:42 at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766) Aug 27 09:41:42 at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
Top level error:
WARNING: The following warnings have been detected: WARNING: Return type, java.util.Map<java.lang.String, ? extends org.apache.pulsar.common.policies.data.NamespaceIsolationData>, of method, public java.util.Map<java.lang.String, ? extends org.apache.pulsar.common.policies.data.NamespaceIsolationData> org.apache.pulsar.broker.admin.impl.ClustersBase.getNamespaceIsolationPolicies(java.lang.String) throws java.lang.Exception, is not resolvable to a concrete type. Aug 27 09:41:42 [ERROR] Tests run: 8, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 357.849 s <<< FAILURE! - in org.apache.flink.connector.pulsar.source.PulsarSourceITCase Aug 27 09:41:42 [ERROR] testMultipleSplits{TestEnvironment, ExternalContext}[1] Time elapsed: 5.391 s <<< ERROR! Aug 27 09:41:42 java.lang.RuntimeException: Failed to fetch next result Aug 27 09:41:42 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109) Aug 27 09:41:42 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80) Aug 27 09:41:42 at org.apache.flink.connectors.test.common.utils.TestDataMatchers$MultipleSplitDataMatcher.matchesSafely(TestDataMatchers.java:151) Aug 27 09:41:42 at org.apache.flink.connectors.test.common.utils.TestDataMatchers$MultipleSplitDataMatcher.matchesSafely(TestDataMatchers.java:133) Aug 27 09:41:42 at org.hamcrest.TypeSafeDiagnosingMatcher.matches(TypeSafeDiagnosingMatcher.java:55) Aug 27 09:41:42 at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:12) Aug 27 09:41:42 at org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8) Aug 27 09:41:42 at org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase.testMultipleSplits(SourceTestSuiteBase.java:156)
Attachments
Issue Links
- duplicates
-
FLINK-23848 PulsarSourceITCase is failed on Azure
- Closed