Matthias Pohl created FLINK-33464:
-------------------------------------
Summary: JoinITCase.testRightOuterJoin failed due to heartbeat
timeout
Key: FLINK-33464
URL: https://issues.apache.org/jira/browse/FLINK-33464
Project: Flink
Issue Type: Sub-task
Components: Runtime / Coordination
Reporter: Matthias Pohl
https://github.com/XComp/flink/actions/runs/6756936036/job/18367079822#step:12:11525
{code}
Error: 21:46:20 21:46:20.936 [ERROR] Tests run: 196, Failures: 0, Errors: 1,
Skipped: 0, Time elapsed: 788.192 s <<< FAILURE! - in
org.apache.flink.table.planner.runtime.batch.sql.join.JoinITCase
Error: 21:46:20 21:46:20.936 [ERROR]
org.apache.flink.table.planner.runtime.batch.sql.join.JoinITCase.testRightOuterJoin
Time elapsed: 68.118 s <<< ERROR!
Nov 04 21:46:20 java.lang.RuntimeException: Failed to fetch next result
Nov 04 21:46:20 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:118)
Nov 04 21:46:20 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:89)
Nov 04 21:46:20 at
org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:230)
Nov 04 21:46:20 at
java.base/java.util.Iterator.forEachRemaining(Iterator.java:132)
Nov 04 21:46:20 at
org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:122)
Nov 04 21:46:20 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:309)
Nov 04 21:46:20 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:145)
Nov 04 21:46:20 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:109)
Nov 04 21:46:20 at
org.apache.flink.table.planner.runtime.batch.sql.join.JoinITCase.testRightOuterJoin(JoinITCase.scala:892)
Nov 04 21:46:20 at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
Nov 04 21:46:20 at
java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
Nov 04 21:46:20 at
java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
Nov 04 21:46:20 at
java.base/java.lang.reflect.Method.invoke(Method.java:566)
Nov 04 21:46:20 at
org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
Nov 04 21:46:20 at
org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
Nov 04 21:46:20 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
Nov 04 21:46:20 at
org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
Nov 04 21:46:20 at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
Nov 04 21:46:20 at
org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
Nov 04 21:46:20 at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
Nov 04 21:46:20 at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
Nov 04 21:46:20 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
Nov 04 21:46:20 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
Nov 04 21:46:20 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
Nov 04 21:46:20 at
org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
Nov 04 21:46:20 at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
Nov 04 21:46:20 at
org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
Nov 04 21:46:20 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
Nov 04 21:46:20 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
Nov 04 21:46:20 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
Nov 04 21:46:20 at
org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.submit(ForkJoinPoolHierarchicalTestExecutorService.java:118)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
Nov 04 21:46:20 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:142)
Nov 04 21:46:20 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:110)
Nov 04 21:46:20 at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
Nov 04 21:46:20 at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
Nov 04 21:46:20 at
java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177)
Nov 04 21:46:20 at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
Nov 04 21:46:20 at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
Nov 04 21:46:20 at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
Nov 04 21:46:20 at
java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
Nov 04 21:46:20 at
java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
Nov 04 21:46:20 at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
Nov 04 21:46:20 at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
Nov 04 21:46:20 at
java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
Nov 04 21:46:20 at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
Nov 04 21:46:20 at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
Nov 04 21:46:20 at
java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
Nov 04 21:46:20 at
java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:274)
Nov 04 21:46:20 at
java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655)
Nov 04 21:46:20 at
java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
Nov 04 21:46:20 at
java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
Nov 04 21:46:20 at
java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
Nov 04 21:46:20 at
java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
Nov 04 21:46:20 at
java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
Nov 04 21:46:20 at
java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
Nov 04 21:46:20 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:110)
Nov 04 21:46:20 at
org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:44)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:129)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
Nov 04 21:46:20 at
org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
Nov 04 21:46:20 at
java.base/java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
Nov 04 21:46:20 at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
Nov 04 21:46:20 at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
Nov 04 21:46:20 at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
Nov 04 21:46:20 at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
Nov 04 21:46:20 at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
Nov 04 21:46:20 Caused by: java.io.IOException: Failed to fetch job execution
result
Nov 04 21:46:20 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:187)
Nov 04 21:46:20 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:123)
Nov 04 21:46:20 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:115)
Nov 04 21:46:20 ... 105 more
Nov 04 21:46:20 Caused by: java.util.concurrent.ExecutionException:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2022)
Nov 04 21:46:20 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:185)
Nov 04 21:46:20 ... 107 more
Nov 04 21:46:20 Caused by:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
Nov 04 21:46:20 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
Nov 04 21:46:20 at
org.apache.flink.runtime.rpc.pekko.PekkoInvocationHandler.lambda$invokeRpc$1(PekkoInvocationHandler.java:268)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
Nov 04 21:46:20 at
org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1287)
Nov 04 21:46:20 at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$1(ClassLoadingUtils.java:93)
Nov 04 21:46:20 at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
Nov 04 21:46:20 at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
Nov 04 21:46:20 at
java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073)
Nov 04 21:46:20 at
org.apache.flink.runtime.concurrent.pekko.ScalaFutureUtils$1.onComplete(ScalaFutureUtils.java:47)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.OnComplete.internal(Future.scala:310)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.OnComplete.internal(Future.scala:307)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.japi$CallbackBridge.apply(Future.scala:234)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.japi$CallbackBridge.apply(Future.scala:231)
Nov 04 21:46:20 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
Nov 04 21:46:20 at
org.apache.flink.runtime.concurrent.pekko.ScalaFutureUtils$DirectExecutionContext.execute(ScalaFutureUtils.java:65)
Nov 04 21:46:20 at
scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:72)
Nov 04 21:46:20 at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:288)
Nov 04 21:46:20 at
scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:288)
Nov 04 21:46:20 at
scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:288)
Nov 04 21:46:20 at
org.apache.pekko.pattern.PromiseActorRef.$bang(AskSupport.scala:629)
Nov 04 21:46:20 at
org.apache.pekko.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:34)
Nov 04 21:46:20 at
org.apache.pekko.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:33)
Nov 04 21:46:20 at
scala.concurrent.Future.$anonfun$andThen$1(Future.scala:536)
Nov 04 21:46:20 at
scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
Nov 04 21:46:20 at
scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
Nov 04 21:46:20 at
scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:73)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:110)
Nov 04 21:46:20 at
scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
Nov 04 21:46:20 at
scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:85)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:110)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.TaskInvocation.run(AbstractDispatcher.scala:59)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.ForkJoinExecutorConfigurator$PekkoForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:57)
Nov 04 21:46:20 ... 5 more
Nov 04 21:46:20 Caused by: org.apache.flink.runtime.JobException: Recovery is
suppressed by NoRestartBackoffTimeStrategy
Nov 04 21:46:20 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:176)
Nov 04 21:46:20 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:107)
Nov 04 21:46:20 at
org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:285)
Nov 04 21:46:20 at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:276)
Nov 04 21:46:20 at
org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:269)
Nov 04 21:46:20 at
org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:765)
Nov 04 21:46:20 at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:742)
Nov 04 21:46:20 at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
Nov 04 21:46:20 at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1645)
Nov 04 21:46:20 at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1144)
Nov 04 21:46:20 at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1084)
Nov 04 21:46:20 at
org.apache.flink.runtime.executiongraph.Execution.fail(Execution.java:785)
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.signalPayloadRelease(SingleLogicalSlot.java:195)
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.release(SingleLogicalSlot.java:182)
Nov 04 21:46:20 at
org.apache.flink.runtime.scheduler.SimpleExecutionSlotAllocator$LogicalSlotHolder.release(SimpleExecutionSlotAllocator.java:203)
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.slotpool.AllocatedSlot.releasePayload(AllocatedSlot.java:152)
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releasePayload(DefaultDeclarativeSlotPool.java:482)
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.freeAndReleaseSlots(DefaultDeclarativeSlotPool.java:474)
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releaseSlots(DefaultDeclarativeSlotPool.java:445)
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.internalReleaseTaskManager(DeclarativeSlotPoolService.java:275)
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.releaseTaskManager(DeclarativeSlotPoolService.java:231)
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.JobMaster.disconnectTaskManager(JobMaster.java:549)
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.handleTaskManagerConnectionLoss(JobMaster.java:1469)
Nov 04 21:46:20 at
org.apache.flink.runtime.jobmaster.JobMaster$TaskManagerHeartbeatListener.notifyHeartbeatTimeout(JobMaster.java:1464)
Nov 04 21:46:20 at
org.apache.flink.runtime.heartbeat.DefaultHeartbeatMonitor.run(DefaultHeartbeatMonitor.java:158)
Nov 04 21:46:20 at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
Nov 04 21:46:20 at
java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
Nov 04 21:46:20 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRunAsync$4(PekkoRpcActor.java:451)
Nov 04 21:46:20 at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
Nov 04 21:46:20 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRunAsync(PekkoRpcActor.java:451)
Nov 04 21:46:20 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:218)
Nov 04 21:46:20 at
org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:85)
Nov 04 21:46:20 at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:168)
Nov 04 21:46:20 at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
Nov 04 21:46:20 at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29)
Nov 04 21:46:20 at
scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
Nov 04 21:46:20 at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
Nov 04 21:46:20 at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29)
Nov 04 21:46:20 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
Nov 04 21:46:20 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
Nov 04 21:46:20 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
Nov 04 21:46:20 at
org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
Nov 04 21:46:20 at
org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
Nov 04 21:46:20 at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
Nov 04 21:46:20 at
org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
Nov 04 21:46:20 at
org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:280)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:241)
Nov 04 21:46:20 at
org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:253)
Nov 04 21:46:20 ... 5 more
Nov 04 21:46:20 Caused by: java.util.concurrent.TimeoutException: Heartbeat of
TaskManager with id 0b0b8b9b-fa3b-4ce7-bd82-0bfdaf85ac79 timed out.
Nov 04 21:46:20 ... 31 more
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
