[
https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411959#comment-17411959
]
Arvid Heise commented on FLINK-23848:
-------------------------------------
Merged into master as
1ca7353b8f91cee62bd78e24fd5af346fe5220ec..ab9b85beacbb3089b3fa1b9adde1adf4a0f7835e.
> PulsarSourceITCase is failed on Azure
> -------------------------------------
>
> Key: FLINK-23848
> URL: https://issues.apache.org/jira/browse/FLINK-23848
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.14.0
> Reporter: Jark Wu
> Assignee: Yufan Sheng
> Priority: Blocker
> Labels: pull-request-available, test-stability
> Fix For: 1.14.0
>
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=22412&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461
> {code}
> 2021-08-17T20:11:53.7228789Z Aug 17 20:11:53 [INFO] Running
> org.apache.flink.connector.pulsar.source.PulsarSourceITCase
> 2021-08-17T20:17:38.2429467Z Aug 17 20:17:38 [ERROR] Tests run: 8, Failures:
> 0, Errors: 1, Skipped: 0, Time elapsed: 344.515 s <<< FAILURE! - in
> org.apache.flink.connector.pulsar.source.PulsarSourceITCase
> 2021-08-17T20:17:38.2430693Z Aug 17 20:17:38 [ERROR]
> testMultipleSplits{TestEnvironment, ExternalContext}[2] Time elapsed: 66.766
> s <<< ERROR!
> 2021-08-17T20:17:38.2431387Z Aug 17 20:17:38 java.lang.RuntimeException:
> Failed to fetch next result
> 2021-08-17T20:17:38.2432035Z Aug 17 20:17:38 at
> org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
> 2021-08-17T20:17:38.2433345Z Aug 17 20:17:38 at
> org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
> 2021-08-17T20:17:38.2434175Z Aug 17 20:17:38 at
> org.apache.flink.connectors.test.common.utils.TestDataMatchers$MultipleSplitDataMatcher.matchesSafely(TestDataMatchers.java:151)
> 2021-08-17T20:17:38.2435028Z Aug 17 20:17:38 at
> org.apache.flink.connectors.test.common.utils.TestDataMatchers$MultipleSplitDataMatcher.matchesSafely(TestDataMatchers.java:133)
> 2021-08-17T20:17:38.2438387Z Aug 17 20:17:38 at
> org.hamcrest.TypeSafeDiagnosingMatcher.matches(TypeSafeDiagnosingMatcher.java:55)
> 2021-08-17T20:17:38.2439100Z Aug 17 20:17:38 at
> org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:12)
> 2021-08-17T20:17:38.2439708Z Aug 17 20:17:38 at
> org.hamcrest.MatcherAssert.assertThat(MatcherAssert.java:8)
> 2021-08-17T20:17:38.2440299Z Aug 17 20:17:38 at
> org.apache.flink.connectors.test.common.testsuites.SourceTestSuiteBase.testMultipleSplits(SourceTestSuiteBase.java:156)
> 2021-08-17T20:17:38.2441007Z Aug 17 20:17:38 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2021-08-17T20:17:38.2441526Z Aug 17 20:17:38 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2021-08-17T20:17:38.2442068Z Aug 17 20:17:38 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-08-17T20:17:38.2442759Z Aug 17 20:17:38 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2021-08-17T20:17:38.2443247Z Aug 17 20:17:38 at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
> 2021-08-17T20:17:38.2443812Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
> 2021-08-17T20:17:38.2444441Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
> 2021-08-17T20:17:38.2445101Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
> 2021-08-17T20:17:38.2445688Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
> 2021-08-17T20:17:38.2446328Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
> 2021-08-17T20:17:38.2447303Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
> 2021-08-17T20:17:38.2448336Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
> 2021-08-17T20:17:38.2448999Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
> 2021-08-17T20:17:38.2449689Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
> 2021-08-17T20:17:38.2450363Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
> 2021-08-17T20:17:38.2451001Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
> 2021-08-17T20:17:38.2451614Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
> 2021-08-17T20:17:38.2452440Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
> 2021-08-17T20:17:38.2453087Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)
> 2021-08-17T20:17:38.2453741Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-08-17T20:17:38.2454682Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:206)
> 2021-08-17T20:17:38.2455320Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:131)
> 2021-08-17T20:17:38.2456064Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:65)
> 2021-08-17T20:17:38.2456715Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
> 2021-08-17T20:17:38.2457455Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-08-17T20:17:38.2458161Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-08-17T20:17:38.2458734Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-08-17T20:17:38.2459327Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-08-17T20:17:38.2459954Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-08-17T20:17:38.2460572Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-08-17T20:17:38.2461161Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-08-17T20:17:38.2461851Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
> 2021-08-17T20:17:38.2462757Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:212)
> 2021-08-17T20:17:38.2463458Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:192)
> 2021-08-17T20:17:38.2464110Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:139)
> 2021-08-17T20:17:38.2464782Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:107)
> 2021-08-17T20:17:38.2465360Z Aug 17 20:17:38 at
> java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> 2021-08-17T20:17:38.2465880Z Aug 17 20:17:38 at
> java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> 2021-08-17T20:17:38.2466376Z Aug 17 20:17:38 at
> java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
> 2021-08-17T20:17:38.2466889Z Aug 17 20:17:38 at
> java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> 2021-08-17T20:17:38.2467382Z Aug 17 20:17:38 at
> java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> 2021-08-17T20:17:38.2467953Z Aug 17 20:17:38 at
> java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> 2021-08-17T20:17:38.2468460Z Aug 17 20:17:38 at
> java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
> 2021-08-17T20:17:38.2468980Z Aug 17 20:17:38 at
> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
> 2021-08-17T20:17:38.2469477Z Aug 17 20:17:38 at
> java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
> 2021-08-17T20:17:38.2470008Z Aug 17 20:17:38 at
> java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
> 2021-08-17T20:17:38.2470551Z Aug 17 20:17:38 at
> java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
> 2021-08-17T20:17:38.2471207Z Aug 17 20:17:38 at
> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> 2021-08-17T20:17:38.2471693Z Aug 17 20:17:38 at
> java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
> 2021-08-17T20:17:38.2472443Z Aug 17 20:17:38 at
> java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
> 2021-08-17T20:17:38.2472960Z Aug 17 20:17:38 at
> java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
> 2021-08-17T20:17:38.2473476Z Aug 17 20:17:38 at
> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
> 2021-08-17T20:17:38.2473973Z Aug 17 20:17:38 at
> java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
> 2021-08-17T20:17:38.2474585Z Aug 17 20:17:38 at
> java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
> 2021-08-17T20:17:38.2475112Z Aug 17 20:17:38 at
> java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
> 2021-08-17T20:17:38.2475634Z Aug 17 20:17:38 at
> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> 2021-08-17T20:17:38.2476273Z Aug 17 20:17:38 at
> java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
> 2021-08-17T20:17:38.2476862Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:107)
> 2021-08-17T20:17:38.2477493Z Aug 17 20:17:38 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:42)
> 2021-08-17T20:17:38.2478211Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
> 2021-08-17T20:17:38.2478837Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-08-17T20:17:38.2479487Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-08-17T20:17:38.2480067Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-08-17T20:17:38.2480635Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-08-17T20:17:38.2481337Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-08-17T20:17:38.2481952Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-08-17T20:17:38.2482690Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-08-17T20:17:38.2483174Z Aug 17 20:17:38 at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2021-08-17T20:17:38.2483802Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
> 2021-08-17T20:17:38.2484527Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
> 2021-08-17T20:17:38.2485170Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-08-17T20:17:38.2485803Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-08-17T20:17:38.2486390Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-08-17T20:17:38.2486958Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-08-17T20:17:38.2487672Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-08-17T20:17:38.2488281Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-08-17T20:17:38.2488873Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-08-17T20:17:38.2489349Z Aug 17 20:17:38 at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2021-08-17T20:17:38.2490063Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
> 2021-08-17T20:17:38.2490785Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
> 2021-08-17T20:17:38.2491420Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-08-17T20:17:38.2492112Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
> 2021-08-17T20:17:38.2492862Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2021-08-17T20:17:38.2493434Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
> 2021-08-17T20:17:38.2494072Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2021-08-17T20:17:38.2494677Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
> 2021-08-17T20:17:38.2495278Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
> 2021-08-17T20:17:38.2495953Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
> 2021-08-17T20:17:38.2496698Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
> 2021-08-17T20:17:38.2497360Z Aug 17 20:17:38 at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
> 2021-08-17T20:17:38.2498003Z Aug 17 20:17:38 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:220)
> 2021-08-17T20:17:38.2498573Z Aug 17 20:17:38 at
> org.junit.platform.launcher.core.DefaultLauncher.lambda$execute$6(DefaultLauncher.java:188)
> 2021-08-17T20:17:38.2499152Z Aug 17 20:17:38 at
> org.junit.platform.launcher.core.DefaultLauncher.withInterceptedStreams(DefaultLauncher.java:202)
> 2021-08-17T20:17:38.2499724Z Aug 17 20:17:38 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:181)
> 2021-08-17T20:17:38.2500254Z Aug 17 20:17:38 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:128)
> 2021-08-17T20:17:38.2500852Z Aug 17 20:17:38 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:150)
> 2021-08-17T20:17:38.2501472Z Aug 17 20:17:38 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:120)
> 2021-08-17T20:17:38.2502089Z Aug 17 20:17:38 at
> org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
> 2021-08-17T20:17:38.2502846Z Aug 17 20:17:38 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
> 2021-08-17T20:17:38.2503399Z Aug 17 20:17:38 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
> 2021-08-17T20:17:38.2503903Z Aug 17 20:17:38 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
> 2021-08-17T20:17:38.2504388Z Aug 17 20:17:38 Caused by: java.io.IOException:
> Failed to fetch job execution result
> 2021-08-17T20:17:38.2504963Z Aug 17 20:17:38 at
> org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:177)
> 2021-08-17T20:17:38.2505838Z Aug 17 20:17:38 at
> org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:120)
> 2021-08-17T20:17:38.2506827Z Aug 17 20:17:38 at
> org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
> 2021-08-17T20:17:38.2507453Z Aug 17 20:17:38 ... 108 more
> 2021-08-17T20:17:38.2508033Z Aug 17 20:17:38 Caused by:
> java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2021-08-17T20:17:38.2508633Z Aug 17 20:17:38 at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2021-08-17T20:17:38.2509149Z Aug 17 20:17:38 at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
> 2021-08-17T20:17:38.2509744Z Aug 17 20:17:38 at
> org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:175)
> 2021-08-17T20:17:38.2510302Z Aug 17 20:17:38 ... 110 more
> 2021-08-17T20:17:38.2510683Z Aug 17 20:17:38 Caused by:
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2021-08-17T20:17:38.2511235Z Aug 17 20:17:38 at
> org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
> 2021-08-17T20:17:38.2511850Z Aug 17 20:17:38 at
> org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137)
> 2021-08-17T20:17:38.2512616Z Aug 17 20:17:38 at
> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
> 2021-08-17T20:17:38.2513144Z Aug 17 20:17:38 at
> java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:628)
> 2021-08-17T20:17:38.2513677Z Aug 17 20:17:38 at
> java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1996)
> 2021-08-17T20:17:38.2514252Z Aug 17 20:17:38 at
> org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:134)
> 2021-08-17T20:17:38.2514944Z Aug 17 20:17:38 at
> org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:174)
> 2021-08-17T20:17:38.2515404Z Aug 17 20:17:38 ... 110 more
> 2021-08-17T20:17:38.2515817Z Aug 17 20:17:38 Caused by:
> org.apache.flink.runtime.JobException: Recovery is suppressed by
> NoRestartBackoffTimeStrategy
> 2021-08-17T20:17:38.2516465Z Aug 17 20:17:38 at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
> 2021-08-17T20:17:38.2517209Z Aug 17 20:17:38 at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
> 2021-08-17T20:17:38.2517937Z Aug 17 20:17:38 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:228)
> 2021-08-17T20:17:38.2518557Z Aug 17 20:17:38 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:218)
> 2021-08-17T20:17:38.2519187Z Aug 17 20:17:38 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:209)
> 2021-08-17T20:17:38.2519817Z Aug 17 20:17:38 at
> org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:679)
> 2021-08-17T20:17:38.2520396Z Aug 17 20:17:38 at
> org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79)
> 2021-08-17T20:17:38.2520981Z Aug 17 20:17:38 at
> org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:438)
> 2021-08-17T20:17:38.2521455Z Aug 17 20:17:38 at
> sun.reflect.GeneratedMethodAccessor65.invoke(Unknown Source)
> 2021-08-17T20:17:38.2521940Z Aug 17 20:17:38 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2021-08-17T20:17:38.2522546Z Aug 17 20:17:38 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2021-08-17T20:17:38.2523083Z Aug 17 20:17:38 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:316)
> 2021-08-17T20:17:38.2523703Z Aug 17 20:17:38 at
> org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
> 2021-08-17T20:17:38.2524327Z Aug 17 20:17:38 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:314)
> 2021-08-17T20:17:38.2524968Z Aug 17 20:17:38 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
> 2021-08-17T20:17:38.2525553Z Aug 17 20:17:38 at
> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
> 2021-08-17T20:17:38.2526116Z Aug 17 20:17:38 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
> 2021-08-17T20:17:38.2526626Z Aug 17 20:17:38 at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
> 2021-08-17T20:17:38.2527144Z Aug 17 20:17:38 at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
> 2021-08-17T20:17:38.2527661Z Aug 17 20:17:38 at
> scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
> 2021-08-17T20:17:38.2528108Z Aug 17 20:17:38 at
> scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
> 2021-08-17T20:17:38.2528590Z Aug 17 20:17:38 at
> akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
> 2021-08-17T20:17:38.2529061Z Aug 17 20:17:38 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
> 2021-08-17T20:17:38.2529553Z Aug 17 20:17:38 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> 2021-08-17T20:17:38.2530025Z Aug 17 20:17:38 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> 2021-08-17T20:17:38.2530474Z Aug 17 20:17:38 at
> akka.actor.Actor.aroundReceive(Actor.scala:537)
> 2021-08-17T20:17:38.2530875Z Aug 17 20:17:38 at
> akka.actor.Actor.aroundReceive$(Actor.scala:535)
> 2021-08-17T20:17:38.2531325Z Aug 17 20:17:38 at
> akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
> 2021-08-17T20:17:38.2531772Z Aug 17 20:17:38 at
> akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
> 2021-08-17T20:17:38.2532202Z Aug 17 20:17:38 at
> akka.actor.ActorCell.invoke(ActorCell.scala:548)
> 2021-08-17T20:17:38.2532786Z Aug 17 20:17:38 at
> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
> 2021-08-17T20:17:38.2533211Z Aug 17 20:17:38 at
> akka.dispatch.Mailbox.run(Mailbox.scala:231)
> 2021-08-17T20:17:38.2533602Z Aug 17 20:17:38 at
> akka.dispatch.Mailbox.exec(Mailbox.scala:243)
> 2021-08-17T20:17:38.2534039Z Aug 17 20:17:38 at
> java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
> 2021-08-17T20:17:38.2534522Z Aug 17 20:17:38 at
> java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
> 2021-08-17T20:17:38.2535026Z Aug 17 20:17:38 at
> java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
> 2021-08-17T20:17:38.2535517Z Aug 17 20:17:38 at
> java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
> 2021-08-17T20:17:38.2536042Z Aug 17 20:17:38 Caused by:
> java.lang.RuntimeException: One or more fetchers have encountered exception
> 2021-08-17T20:17:38.2536626Z Aug 17 20:17:38 at
> org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:199)
> 2021-08-17T20:17:38.2537278Z Aug 17 20:17:38 at
> org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:167)
> 2021-08-17T20:17:38.2537965Z Aug 17 20:17:38 at
> org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:128)
> 2021-08-17T20:17:38.2538630Z Aug 17 20:17:38 at
> org.apache.flink.connector.pulsar.source.reader.source.PulsarOrderedSourceReader.pollNext(PulsarOrderedSourceReader.java:108)
> 2021-08-17T20:17:38.2539265Z Aug 17 20:17:38 at
> org.apache.flink.streaming.api.operators.SourceOperator.pollNext(SourceOperator.java:364)
> 2021-08-17T20:17:38.2539842Z Aug 17 20:17:38 at
> org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:324)
> 2021-08-17T20:17:38.2540525Z Aug 17 20:17:38 at
> org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68)
> 2021-08-17T20:17:38.2541133Z Aug 17 20:17:38 at
> org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
> 2021-08-17T20:17:38.2541698Z Aug 17 20:17:38 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:489)
> 2021-08-17T20:17:38.2542427Z Aug 17 20:17:38 at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
> 2021-08-17T20:17:38.2542997Z Aug 17 20:17:38 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:819)
> 2021-08-17T20:17:38.2543541Z Aug 17 20:17:38 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:746)
> 2021-08-17T20:17:38.2544093Z Aug 17 20:17:38 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:785)
> 2021-08-17T20:17:38.2544719Z Aug 17 20:17:38 at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:728)
> 2021-08-17T20:17:38.2545205Z Aug 17 20:17:38 at
> org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:786)
> 2021-08-17T20:17:38.2545642Z Aug 17 20:17:38 at
> org.apache.flink.runtime.taskmanager.Task.run(Task.java:572)
> 2021-08-17T20:17:38.2546045Z Aug 17 20:17:38 at
> java.lang.Thread.run(Thread.java:748)
> 2021-08-17T20:17:38.2546509Z Aug 17 20:17:38 Caused by:
> java.lang.RuntimeException: SplitFetcher thread 0 received unexpected
> exception while polling the records
> 2021-08-17T20:17:38.2547099Z Aug 17 20:17:38 at
> org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:146)
> 2021-08-17T20:17:38.2547716Z Aug 17 20:17:38 at
> org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:101)
> 2021-08-17T20:17:38.2548241Z Aug 17 20:17:38 at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
> 2021-08-17T20:17:38.2548689Z Aug 17 20:17:38 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 2021-08-17T20:17:38.2549159Z Aug 17 20:17:38 at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2021-08-17T20:17:38.2549659Z Aug 17 20:17:38 at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2021-08-17T20:17:38.2550030Z Aug 17 20:17:38 ... 1 more
> 2021-08-17T20:17:38.2550437Z Aug 17 20:17:38 Caused by:
> org.apache.pulsar.client.api.PulsarClientException$TimeoutException: 2
> request timedout after ms 30000
> 2021-08-17T20:17:38.2551017Z Aug 17 20:17:38 at
> org.apache.pulsar.client.api.PulsarClientException.unwrap(PulsarClientException.java:961)
> 2021-08-17T20:17:38.2551552Z Aug 17 20:17:38 at
> org.apache.pulsar.client.impl.ConsumerBuilderImpl.subscribe(ConsumerBuilderImpl.java:97)
> 2021-08-17T20:17:38.2552171Z Aug 17 20:17:38 at
> org.apache.flink.connector.pulsar.source.config.PulsarSourceConfigUtils.createConsumer(PulsarSourceConfigUtils.java:256)
> 2021-08-17T20:17:38.2552894Z Aug 17 20:17:38 at
> org.apache.flink.connector.pulsar.source.config.PulsarSourceConfigUtils.createConsumer(PulsarSourceConfigUtils.java:229)
> 2021-08-17T20:17:38.2553632Z Aug 17 20:17:38 at
> org.apache.flink.connector.pulsar.source.reader.split.PulsarPartitionSplitReaderBase.lambda$createPulsarConsumer$1(PulsarPartitionSplitReaderBase.java:262)
> 2021-08-17T20:17:38.2554335Z Aug 17 20:17:38 at
> org.apache.flink.connector.pulsar.common.utils.PulsarExceptionUtils.sneaky(PulsarExceptionUtils.java:69)
> 2021-08-17T20:17:38.2554961Z Aug 17 20:17:38 at
> org.apache.flink.connector.pulsar.common.utils.PulsarExceptionUtils.sneakyClient(PulsarExceptionUtils.java:46)
> 2021-08-17T20:17:38.2555654Z Aug 17 20:17:38 at
> org.apache.flink.connector.pulsar.source.reader.split.PulsarPartitionSplitReaderBase.createPulsarConsumer(PulsarPartitionSplitReaderBase.java:261)
> 2021-08-17T20:17:38.2556427Z Aug 17 20:17:38 at
> org.apache.flink.connector.pulsar.source.reader.split.PulsarPartitionSplitReaderBase.createPulsarConsumer(PulsarPartitionSplitReaderBase.java:238)
> 2021-08-17T20:17:38.2557199Z Aug 17 20:17:38 at
> org.apache.flink.connector.pulsar.source.reader.split.PulsarPartitionSplitReaderBase.handleSplitsChanges(PulsarPartitionSplitReaderBase.java:178)
> 2021-08-17T20:17:38.2558037Z Aug 17 20:17:38 at
> org.apache.flink.connector.pulsar.source.reader.split.PulsarOrderedPartitionSplitReader.handleSplitsChanges(PulsarOrderedPartitionSplitReader.java:52)
> 2021-08-17T20:17:38.2558793Z Aug 17 20:17:38 at
> org.apache.flink.connector.base.source.reader.fetcher.AddSplitsTask.run(AddSplitsTask.java:49)
> 2021-08-17T20:17:38.2559363Z Aug 17 20:17:38 at
> org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:138)
> 2021-08-17T20:17:38.2559776Z Aug 17 20:17:38 ... 6 more
> 2021-08-17T20:17:38.2560000Z Aug 17 20:17:38
> 2021-08-17T20:17:38.6992614Z Aug 17 20:17:38 [INFO]
> 2021-08-17T20:17:38.6993159Z Aug 17 20:17:38 [INFO] Results:
> 2021-08-17T20:17:38.6994058Z Aug 17 20:17:38 [INFO]
> 2021-08-17T20:17:38.6994436Z Aug 17 20:17:38 [ERROR] Errors:
> 2021-08-17T20:17:38.6996010Z Aug 17 20:17:38 [ERROR]
> PulsarSourceITCase>SourceTestSuiteBase.testMultipleSplits:156 ยป Runtime
> Failed...
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
