[
https://issues.apache.org/jira/browse/FLINK-24030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405962#comment-17405962
]
Piotr Nowojski commented on FLINK-24030:
----------------------------------------
Are you sure? The exception stack trace is different.
> PulsarSourceITCase>SourceTestSuiteBase.testMultipleSplits failed
> ----------------------------------------------------------------
>
> Key: FLINK-24030
> URL: https://issues.apache.org/jira/browse/FLINK-24030
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.14.0
> Reporter: Piotr Nowojski
> Priority: Major
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=22936&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461
> root cause:
> {noformat}
> 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)
> {noformat}
> Top level error:
> {noformat}
> 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)
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
