You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Roman Khachatryan (Jira)" <ji...@apache.org> on 2022/03/14 10:58:00 UTC
[jira] [Created] (FLINK-26635) KafkaSourceE2ECase.testMultipleSplits failed on azure with Correlation id for response does not match request
Roman Khachatryan created FLINK-26635:
-----------------------------------------
Summary: KafkaSourceE2ECase.testMultipleSplits failed on azure with Correlation id for response does not match request
Key: FLINK-26635
URL: https://issues.apache.org/jira/browse/FLINK-26635
Project: Flink
Issue Type: Bug
Components: Connectors / Kafka
Affects Versions: 1.15.0
Reporter: Roman Khachatryan
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=32981&view=logs&j=af184cdd-c6d8-5084-0b69-7e9c67b35f7a&t=160c9ae5-96fd-516e-1c91-deb81f59292a&l=14703
{code}
2022-03-14T03:35:34.8710354Z Mar 14 03:35:34 [ERROR] Tests run: 16, Failures: 0, Errors: 1, Skipped: 0, Time elapsed: 184.49 s <<< FAILURE! - in org.apache.flink.tests.util.kafka.KafkaSourceE2ECase
2022-03-14T03:35:34.8881150Z Mar 14 03:35:34 [ERROR] org.apache.flink.tests.util.kafka.KafkaSourceE2ECase.testMultipleSplits(TestEnvironment, DataStreamSourceExternalContext, CheckpointingMode)[1] Time elapsed: 3.769 s <<< ERROR!
2022-03-14T03:35:34.8882315Z Mar 14 03:35:34 java.lang.RuntimeException: Failed to fetch next result
2022-03-14T03:35:34.8886537Z Mar 14 03:35:34 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
2022-03-14T03:35:34.8887677Z Mar 14 03:35:34 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
2022-03-14T03:35:34.8888672Z Mar 14 03:35:34 at org.apache.flink.connector.testframe.utils.CollectIteratorAssert.compareWithExactlyOnceSemantic(CollectIteratorAssert.java:116)
2022-03-14T03:35:34.8889715Z Mar 14 03:35:34 at org.apache.flink.connector.testframe.utils.CollectIteratorAssert.matchesRecordsFromSource(CollectIteratorAssert.java:71)
2022-03-14T03:35:34.8890700Z Mar 14 03:35:34 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.checkResultWithSemantic(SourceTestSuiteBase.java:769)
2022-03-14T03:35:34.8891663Z Mar 14 03:35:34 at org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.testMultipleSplits(SourceTestSuiteBase.java:218)
2022-03-14T03:35:34.8892432Z Mar 14 03:35:34 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-03-14T03:35:34.8893159Z Mar 14 03:35:34 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-03-14T03:35:34.8893940Z Mar 14 03:35:34 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-03-14T03:35:34.8894691Z Mar 14 03:35:34 at java.lang.reflect.Method.invoke(Method.java:498)
2022-03-14T03:35:34.8895694Z Mar 14 03:35:34 at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)
2022-03-14T03:35:34.8896532Z Mar 14 03:35:34 at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
2022-03-14T03:35:34.8897443Z Mar 14 03:35:34 at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
2022-03-14T03:35:34.8898353Z Mar 14 03:35:34 at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
2022-03-14T03:35:34.8899200Z Mar 14 03:35:34 at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
2022-03-14T03:35:34.8901355Z Mar 14 03:35:34 at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
2022-03-14T03:35:34.8902346Z Mar 14 03:35:34 at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
2022-03-14T03:35:34.8903536Z Mar 14 03:35:34 at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
2022-03-14T03:35:34.8904460Z Mar 14 03:35:34 at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
2022-03-14T03:35:34.8905743Z Mar 14 03:35:34 at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
2022-03-14T03:35:34.8906674Z Mar 14 03:35:34 at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
2022-03-14T03:35:34.8907606Z Mar 14 03:35:34 at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
2022-03-14T03:35:34.8908447Z Mar 14 03:35:34 at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
2022-03-14T03:35:34.8909283Z Mar 14 03:35:34 at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
2022-03-14T03:35:34.8910366Z Mar 14 03:35:34 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214)
2022-03-14T03:35:34.8919086Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-03-14T03:35:34.8920132Z Mar 14 03:35:34 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210)
2022-03-14T03:35:34.8921035Z Mar 14 03:35:34 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)
2022-03-14T03:35:34.8921939Z Mar 14 03:35:34 at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66)
2022-03-14T03:35:34.8922823Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-03-14T03:35:34.8923891Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-03-14T03:35:34.8924777Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-03-14T03:35:34.8925630Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-03-14T03:35:34.8926447Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-03-14T03:35:34.8929025Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-03-14T03:35:34.8929787Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-03-14T03:35:34.8930641Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-03-14T03:35:34.8931647Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
2022-03-14T03:35:34.8932547Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
2022-03-14T03:35:34.8933378Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
2022-03-14T03:35:34.8934169Z Mar 14 03:35:34 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:139)
2022-03-14T03:35:34.8944148Z Mar 14 03:35:34 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:107)
2022-03-14T03:35:34.8944948Z Mar 14 03:35:34 at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-03-14T03:35:34.8946063Z Mar 14 03:35:34 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-03-14T03:35:34.8946706Z Mar 14 03:35:34 at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
2022-03-14T03:35:34.8947336Z Mar 14 03:35:34 at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-03-14T03:35:34.8947957Z Mar 14 03:35:34 at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
2022-03-14T03:35:34.8948572Z Mar 14 03:35:34 at java.util.LinkedList$LLSpliterator.forEachRemaining(LinkedList.java:1235)
2022-03-14T03:35:34.8949208Z Mar 14 03:35:34 at java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:647)
2022-03-14T03:35:34.8949844Z Mar 14 03:35:34 at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2022-03-14T03:35:34.8950484Z Mar 14 03:35:34 at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-03-14T03:35:34.8951124Z Mar 14 03:35:34 at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-03-14T03:35:34.8951760Z Mar 14 03:35:34 at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-03-14T03:35:34.9020751Z Mar 14 03:35:34 at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-03-14T03:35:34.9021931Z Mar 14 03:35:34 at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-03-14T03:35:34.9022793Z Mar 14 03:35:34 at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-03-14T03:35:34.9023609Z Mar 14 03:35:34 at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-03-14T03:35:34.9024435Z Mar 14 03:35:34 at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
2022-03-14T03:35:34.9025407Z Mar 14 03:35:34 at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
2022-03-14T03:35:34.9026267Z Mar 14 03:35:34 at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-03-14T03:35:34.9027098Z Mar 14 03:35:34 at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-03-14T03:35:34.9027939Z Mar 14 03:35:34 at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
2022-03-14T03:35:34.9029376Z Mar 14 03:35:34 at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
2022-03-14T03:35:34.9030195Z Mar 14 03:35:34 at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-03-14T03:35:34.9030928Z Mar 14 03:35:34 at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
2022-03-14T03:35:34.9031770Z Mar 14 03:35:34 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:107)
2022-03-14T03:35:34.9032662Z Mar 14 03:35:34 at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:42)
2022-03-14T03:35:34.9033580Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
2022-03-14T03:35:34.9034762Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-03-14T03:35:34.9035683Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-03-14T03:35:34.9036521Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-03-14T03:35:34.9037350Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-03-14T03:35:34.9038243Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-03-14T03:35:34.9039109Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-03-14T03:35:34.9040063Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-03-14T03:35:34.9040840Z Mar 14 03:35:34 at java.util.ArrayList.forEach(ArrayList.java:1259)
2022-03-14T03:35:34.9041713Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
2022-03-14T03:35:34.9042698Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-03-14T03:35:34.9043601Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-03-14T03:35:34.9044691Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-03-14T03:35:34.9045592Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-03-14T03:35:34.9046437Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-03-14T03:35:34.9047325Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-03-14T03:35:34.9048194Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-03-14T03:35:34.9049040Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-03-14T03:35:34.9049767Z Mar 14 03:35:34 at java.util.ArrayList.forEach(ArrayList.java:1259)
2022-03-14T03:35:34.9050634Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
2022-03-14T03:35:34.9051662Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
2022-03-14T03:35:34.9052553Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-03-14T03:35:34.9053464Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
2022-03-14T03:35:34.9054283Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
2022-03-14T03:35:34.9055116Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
2022-03-14T03:35:34.9062700Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
2022-03-14T03:35:34.9063472Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
2022-03-14T03:35:34.9064197Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
2022-03-14T03:35:34.9065436Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
2022-03-14T03:35:34.9066348Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
2022-03-14T03:35:34.9067155Z Mar 14 03:35:34 at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
2022-03-14T03:35:34.9067922Z Mar 14 03:35:34 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
2022-03-14T03:35:34.9068693Z Mar 14 03:35:34 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
2022-03-14T03:35:34.9069484Z Mar 14 03:35:34 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
2022-03-14T03:35:34.9070406Z Mar 14 03:35:34 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
2022-03-14T03:35:34.9071215Z Mar 14 03:35:34 at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
2022-03-14T03:35:34.9071934Z Mar 14 03:35:34 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
2022-03-14T03:35:34.9072600Z Mar 14 03:35:34 at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
2022-03-14T03:35:34.9073341Z Mar 14 03:35:34 at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
2022-03-14T03:35:34.9074112Z Mar 14 03:35:34 at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
2022-03-14T03:35:34.9074870Z Mar 14 03:35:34 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
2022-03-14T03:35:34.9075650Z Mar 14 03:35:34 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
2022-03-14T03:35:34.9076421Z Mar 14 03:35:34 at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:128)
2022-03-14T03:35:34.9156821Z Mar 14 03:35:34 at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
2022-03-14T03:35:34.9164214Z Mar 14 03:35:34 at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
2022-03-14T03:35:34.9165150Z Mar 14 03:35:34 at org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
2022-03-14T03:35:34.9165935Z Mar 14 03:35:34 at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
2022-03-14T03:35:34.9166625Z Mar 14 03:35:34 Caused by: java.io.IOException: Failed to fetch job execution result
2022-03-14T03:35:34.9167461Z Mar 14 03:35:34 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184)
2022-03-14T03:35:34.9168406Z Mar 14 03:35:34 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121)
2022-03-14T03:35:34.9169358Z Mar 14 03:35:34 at org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
2022-03-14T03:35:34.9170082Z Mar 14 03:35:34 ... 113 more
2022-03-14T03:35:34.9170816Z Mar 14 03:35:34 Caused by: java.util.concurrent.ExecutionException: org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: 7a9a24340c6344d39c75afe7db94c480)
2022-03-14T03:35:34.9171708Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2022-03-14T03:35:34.9172460Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2022-03-14T03:35:34.9173331Z Mar 14 03:35:34 at org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182)
2022-03-14T03:35:34.9174215Z Mar 14 03:35:34 ... 115 more
2022-03-14T03:35:34.9174890Z Mar 14 03:35:34 Caused by: org.apache.flink.client.program.ProgramInvocationException: Job failed (JobID: 7a9a24340c6344d39c75afe7db94c480)
2022-03-14T03:35:34.9175803Z Mar 14 03:35:34 at org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:130)
2022-03-14T03:35:34.9176659Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2022-03-14T03:35:34.9177436Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
2022-03-14T03:35:34.9178223Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-03-14T03:35:34.9178996Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-03-14T03:35:34.9179909Z Mar 14 03:35:34 at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:403)
2022-03-14T03:35:34.9180760Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-03-14T03:35:34.9181546Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-03-14T03:35:34.9182345Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-03-14T03:35:34.9183114Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-03-14T03:35:34.9183978Z Mar 14 03:35:34 at org.apache.flink.client.program.rest.RestClusterClient.lambda$pollResourceAsync$26(RestClusterClient.java:708)
2022-03-14T03:35:34.9184833Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-03-14T03:35:34.9185885Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-03-14T03:35:34.9186688Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-03-14T03:35:34.9187524Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
2022-03-14T03:35:34.9188354Z Mar 14 03:35:34 at org.apache.flink.util.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:403)
2022-03-14T03:35:34.9189165Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
2022-03-14T03:35:34.9189969Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
2022-03-14T03:35:34.9190766Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
2022-03-14T03:35:34.9191532Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:575)
2022-03-14T03:35:34.9192315Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:943)
2022-03-14T03:35:34.9193105Z Mar 14 03:35:34 at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
2022-03-14T03:35:34.9193883Z Mar 14 03:35:34 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2022-03-14T03:35:34.9194658Z Mar 14 03:35:34 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2022-03-14T03:35:34.9195336Z Mar 14 03:35:34 at java.lang.Thread.run(Thread.java:750)
2022-03-14T03:35:34.9195973Z Mar 14 03:35:34 Caused by: org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-03-14T03:35:34.9196745Z Mar 14 03:35:34 at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2022-03-14T03:35:34.9197605Z Mar 14 03:35:34 at org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:128)
2022-03-14T03:35:34.9198305Z Mar 14 03:35:34 ... 24 more
2022-03-14T03:35:34.9199003Z Mar 14 03:35:34 Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
2022-03-14T03:35:34.9199907Z Mar 14 03:35:34 at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
2022-03-14T03:35:34.9200928Z Mar 14 03:35:34 at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
2022-03-14T03:35:34.9201875Z Mar 14 03:35:34 at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
2022-03-14T03:35:34.9202742Z Mar 14 03:35:34 at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
2022-03-14T03:35:34.9203626Z Mar 14 03:35:34 at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
2022-03-14T03:35:34.9204648Z Mar 14 03:35:34 at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:739)
2022-03-14T03:35:34.9205479Z Mar 14 03:35:34 at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:78)
2022-03-14T03:35:34.9206307Z Mar 14 03:35:34 at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:443)
2022-03-14T03:35:34.9207043Z Mar 14 03:35:34 at sun.reflect.GeneratedMethodAccessor43.invoke(Unknown Source)
2022-03-14T03:35:34.9207767Z Mar 14 03:35:34 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-03-14T03:35:34.9208496Z Mar 14 03:35:34 at java.lang.reflect.Method.invoke(Method.java:498)
2022-03-14T03:35:34.9209253Z Mar 14 03:35:34 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
2022-03-14T03:35:34.9210157Z Mar 14 03:35:34 at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-03-14T03:35:34.9213024Z Mar 14 03:35:34 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
2022-03-14T03:35:34.9213734Z Mar 14 03:35:34 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
2022-03-14T03:35:34.9214466Z Mar 14 03:35:34 at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
2022-03-14T03:35:34.9215164Z Mar 14 03:35:34 at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
2022-03-14T03:35:34.9215796Z Mar 14 03:35:34 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-03-14T03:35:34.9216375Z Mar 14 03:35:34 at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-03-14T03:35:34.9216953Z Mar 14 03:35:34 at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2022-03-14T03:35:34.9217529Z Mar 14 03:35:34 at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2022-03-14T03:35:34.9218119Z Mar 14 03:35:34 at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-03-14T03:35:34.9218722Z Mar 14 03:35:34 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2022-03-14T03:35:34.9219309Z Mar 14 03:35:34 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-03-14T03:35:34.9219911Z Mar 14 03:35:34 at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-03-14T03:35:34.9220473Z Mar 14 03:35:34 at akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-03-14T03:35:34.9220996Z Mar 14 03:35:34 at akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-03-14T03:35:34.9221551Z Mar 14 03:35:34 at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-03-14T03:35:34.9222125Z Mar 14 03:35:34 at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2022-03-14T03:35:34.9222649Z Mar 14 03:35:34 at akka.actor.ActorCell.invoke(ActorCell.scala:548)
2022-03-14T03:35:34.9223194Z Mar 14 03:35:34 at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-03-14T03:35:34.9223835Z Mar 14 03:35:34 at akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-03-14T03:35:34.9224350Z Mar 14 03:35:34 at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-03-14T03:35:34.9224897Z Mar 14 03:35:34 at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-03-14T03:35:34.9225724Z Mar 14 03:35:34 at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-03-14T03:35:34.9226352Z Mar 14 03:35:34 at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-03-14T03:35:34.9226973Z Mar 14 03:35:34 at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-03-14T03:35:34.9227586Z Mar 14 03:35:34 Caused by: java.lang.RuntimeException: One or more fetchers have encountered exception
2022-03-14T03:35:34.9228293Z Mar 14 03:35:34 at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:225)
2022-03-14T03:35:34.9229188Z Mar 14 03:35:34 at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:169)
2022-03-14T03:35:34.9229945Z Mar 14 03:35:34 at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:130)
2022-03-14T03:35:34.9230654Z Mar 14 03:35:34 at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:382)
2022-03-14T03:35:34.9231384Z Mar 14 03:35:34 at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68)
2022-03-14T03:35:34.9232150Z Mar 14 03:35:34 at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
2022-03-14T03:35:34.9232882Z Mar 14 03:35:34 at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:519)
2022-03-14T03:35:34.9448620Z Mar 14 03:35:34 at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
2022-03-14T03:35:34.9449562Z Mar 14 03:35:34 at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:804)
2022-03-14T03:35:34.9450251Z Mar 14 03:35:34 at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:753)
2022-03-14T03:35:34.9450905Z Mar 14 03:35:34 at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948)
2022-03-14T03:35:34.9451568Z Mar 14 03:35:34 at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927)
2022-03-14T03:35:34.9452174Z Mar 14 03:35:34 at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741)
2022-03-14T03:35:34.9452755Z Mar 14 03:35:34 at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
2022-03-14T03:35:34.9453279Z Mar 14 03:35:34 at java.lang.Thread.run(Thread.java:750)
2022-03-14T03:35:34.9453862Z Mar 14 03:35:34 Caused by: java.lang.RuntimeException: SplitFetcher thread 0 received unexpected exception while polling the records
2022-03-14T03:35:34.9454590Z Mar 14 03:35:34 at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:150)
2022-03-14T03:35:34.9455308Z Mar 14 03:35:34 at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:105)
2022-03-14T03:35:34.9455984Z Mar 14 03:35:34 at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
2022-03-14T03:35:34.9456573Z Mar 14 03:35:34 at java.util.concurrent.FutureTask.run(FutureTask.java:266)
2022-03-14T03:35:34.9457179Z Mar 14 03:35:34 at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
2022-03-14T03:35:34.9457833Z Mar 14 03:35:34 at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
2022-03-14T03:35:34.9458315Z Mar 14 03:35:34 ... 1 more
2022-03-14T03:35:34.9468219Z Mar 14 03:35:34 Caused by: org.apache.kafka.common.requests.CorrelationIdMismatchException: Correlation id for response (1179651) does not match request (0), request header: RequestHeader(apiKey=API_VERSIONS, apiVersion=3, clientId=kafka-source-external-context-5202920971269984176-1, correlationId=0)
2022-03-14T03:35:34.9469400Z Mar 14 03:35:34 at org.apache.kafka.common.requests.AbstractResponse.parseResponse(AbstractResponse.java:106)
2022-03-14T03:35:34.9470096Z Mar 14 03:35:34 at org.apache.kafka.clients.NetworkClient.parseResponse(NetworkClient.java:730)
2022-03-14T03:35:34.9470775Z Mar 14 03:35:34 at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:875)
2022-03-14T03:35:34.9471425Z Mar 14 03:35:34 at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:570)
2022-03-14T03:35:34.9472109Z Mar 14 03:35:34 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:265)
2022-03-14T03:35:34.9472868Z Mar 14 03:35:34 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236)
2022-03-14T03:35:34.9479712Z Mar 14 03:35:34 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:227)
2022-03-14T03:35:34.9480551Z Mar 14 03:35:34 at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.awaitMetadataUpdate(ConsumerNetworkClient.java:164)
2022-03-14T03:35:34.9481310Z Mar 14 03:35:34 at org.apache.kafka.clients.consumer.internals.Fetcher.fetchOffsetsByTimes(Fetcher.java:557)
2022-03-14T03:35:34.9482022Z Mar 14 03:35:34 at org.apache.kafka.clients.consumer.internals.Fetcher.beginningOrEndOffset(Fetcher.java:581)
2022-03-14T03:35:34.9482711Z Mar 14 03:35:34 at org.apache.kafka.clients.consumer.internals.Fetcher.endOffsets(Fetcher.java:569)
2022-03-14T03:35:34.9483382Z Mar 14 03:35:34 at org.apache.kafka.clients.consumer.KafkaConsumer.endOffsets(KafkaConsumer.java:2215)
2022-03-14T03:35:34.9484065Z Mar 14 03:35:34 at org.apache.kafka.clients.consumer.KafkaConsumer.endOffsets(KafkaConsumer.java:2187)
2022-03-14T03:35:34.9484869Z Mar 14 03:35:34 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.acquireAndSetStoppingOffsets(KafkaPartitionSplitReader.java:302)
2022-03-14T03:35:34.9485781Z Mar 14 03:35:34 at org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReader.handleSplitsChanges(KafkaPartitionSplitReader.java:200)
2022-03-14T03:35:34.9486711Z Mar 14 03:35:34 at org.apache.flink.connector.base.source.reader.fetcher.AddSplitsTask.run(AddSplitsTask.java:51)
2022-03-14T03:35:34.9488002Z Mar 14 03:35:34 at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:142)
2022-03-14T03:35:34.9488547Z Mar 14 03:35:34 ... 6 more
2022-03-14T03:35:34.9488851Z Mar 14 03:35:34
2022-03-14T03:35:34.9489283Z Mar 14 03:35:34 [INFO] Running org.apache.flink.tests.util.kafka.SQLClientSchemaRegistryITCase
2022-03-14T03:37:44.3653205Z Mar 14 03:37:44 [WARNING] Tests run: 3, Failures: 0, Errors: 0, Skipped: 1, Time elapsed: 129.492 s - in org.apache.flink.tests.util.kafka.SQLClientSchemaRegistryITCase
2022-03-14T03:37:44.7467558Z Mar 14 03:37:44 [INFO]
2022-03-14T03:37:44.7467990Z Mar 14 03:37:44 [INFO] Results:
2022-03-14T03:37:44.7468610Z Mar 14 03:37:44 [INFO]
2022-03-14T03:37:44.7468986Z Mar 14 03:37:44 [ERROR] Errors:
2022-03-14T03:37:44.7474040Z Mar 14 03:37:44 [ERROR] KafkaSourceE2ECase>SourceTestSuiteBase.testMultipleSplits:218->SourceTestSuiteBase.checkResultWithSemantic:769 ยป Runtime
{code}
--
This message was sent by Atlassian Jira
(v8.20.1#820001)