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)