[
https://issues.apache.org/jira/browse/FLINK-33280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yuxin Tan closed FLINK-33280.
-----------------------------
Resolution: Fixed
> tests stage: HybridShuffleITCase.testHybridSelectiveExchangesRestart due to
> timeout
> -----------------------------------------------------------------------------------
>
> Key: FLINK-33280
> URL: https://issues.apache.org/jira/browse/FLINK-33280
> Project: Flink
> Issue Type: Sub-task
> Reporter: Matthias Pohl
> Priority: Major
> Labels: test-stability
>
> [https://github.com/XComp/flink/actions/runs/6529754573/job/17728223099#step:12:9120]
> {code:java}
> Oct 16 09:13:15 java.lang.AssertionError:
> org.apache.flink.runtime.JobException: org.apache.flink.runtime.JobException:
> Recovery is suppressed by
> FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=10,
> backoffTimeMS=0)
> 8959Oct 16 09:13:15 at
> org.apache.flink.test.runtime.JobGraphRunningUtil.execute(JobGraphRunningUtil.java:59)
> 8960Oct 16 09:13:15 at
> org.apache.flink.test.runtime.BatchShuffleITCaseBase.executeJob(BatchShuffleITCaseBase.java:118)
> 8961Oct 16 09:13:15 at
> org.apache.flink.test.runtime.HybridShuffleITCase.testHybridSelectiveExchangesRestart(HybridShuffleITCase.java:77)
> 8962Oct 16 09:13:15 at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 8963Oct 16 09:13:15 at
> java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 8964Oct 16 09:13:15 at
> java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 8965Oct 16 09:13:15 at
> java.base/java.lang.reflect.Method.invoke(Method.java:566)
> 8966Oct 16 09:13:15 at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:727)
> 8967Oct 16 09:13:15 at
> org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
> 8968Oct 16 09:13:15 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
> 8969Oct 16 09:13:15 at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:156)
> 8970Oct 16 09:13:15 at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:147)
> 8971Oct 16 09:13:15 at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:94)
> 8972Oct 16 09:13:15 at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(InterceptingExecutableInvoker.java:103)
> 8973Oct 16 09:13:15 at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.lambda$invoke$0(InterceptingExecutableInvoker.java:93)
> 8974Oct 16 09:13:15 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
> 8975Oct 16 09:13:15 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
> 8976Oct 16 09:13:15 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
> 8977Oct 16 09:13:15 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
> 8978Oct 16 09:13:15 at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:92)
> 8979Oct 16 09:13:15 at
> org.junit.jupiter.engine.execution.InterceptingExecutableInvoker.invoke(InterceptingExecutableInvoker.java:86)
> 8980Oct 16 09:13:15 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:217)
> 8981Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 8982Oct 16 09:13:15 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:213)
> 8983Oct 16 09:13:15 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:138)
> 8984Oct 16 09:13:15 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:68)
> 8985Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
> 8986Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 8987Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
> 8988Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 8989Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
> 8990Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 8991Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
> 8992Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
> 8993Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
> 8994Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.submit(ForkJoinPoolHierarchicalTestExecutorService.java:118)
> 8995Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
> 8996Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
> 8997Oct 16 09:13:15 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:142)
> 8998Oct 16 09:13:15 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:110)
> 8999Oct 16 09:13:15 at
> java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> 9000Oct 16 09:13:15 at
> java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
> 9001Oct 16 09:13:15 at
> java.base/java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:177)
> 9002Oct 16 09:13:15 at
> java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
> 9003Oct 16 09:13:15 at
> java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> 9004Oct 16 09:13:15 at
> java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
> 9005Oct 16 09:13:15 at
> java.base/java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195)
> 9006Oct 16 09:13:15 at
> java.base/java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
> 9007Oct 16 09:13:15 at
> java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
> 9008Oct 16 09:13:15 at
> java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
> 9009Oct 16 09:13:15 at
> java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
> 9010Oct 16 09:13:15 at
> java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
> 9011Oct 16 09:13:15 at
> java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> 9012Oct 16 09:13:15 at
> java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
> 9013Oct 16 09:13:15 at
> java.base/java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:274)
> 9014Oct 16 09:13:15 at
> java.base/java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1655)
> 9015Oct 16 09:13:15 at
> java.base/java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484)
> 9016Oct 16 09:13:15 at
> java.base/java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474)
> 9017Oct 16 09:13:15 at
> java.base/java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
> 9018Oct 16 09:13:15 at
> java.base/java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
> 9019Oct 16 09:13:15 at
> java.base/java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> 9020Oct 16 09:13:15 at
> java.base/java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:497)
> 9021Oct 16 09:13:15 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:110)
> 9022Oct 16 09:13:15 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:44)
> 9023Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
> 9024Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 9025Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
> 9026Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 9027Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
> 9028Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 9029Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
> 9030Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
> 9031Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
> 9032Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.executeNonConcurrentTasks(ForkJoinPoolHierarchicalTestExecutorService.java:155)
> 9033Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:135)
> 9034Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
> 9035Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 9036Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
> 9037Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 9038Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
> 9039Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 9040Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
> 9041Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
> 9042Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
> 9043Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService.invokeAll(ForkJoinPoolHierarchicalTestExecutorService.java:129)
> 9044Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
> 9045Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 9046Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
> 9047Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 9048Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
> 9049Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 9050Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
> 9051Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
> 9052Oct 16 09:13:15 at
> org.junit.platform.engine.support.hierarchical.ForkJoinPoolHierarchicalTestExecutorService$ExclusiveTask.compute(ForkJoinPoolHierarchicalTestExecutorService.java:185)
> 9053Oct 16 09:13:15 at
> java.base/java.util.concurrent.RecursiveAction.exec(RecursiveAction.java:189)
> 9054Oct 16 09:13:15 at
> java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:290)
> 9055Oct 16 09:13:15 at
> java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1020)
> 9056Oct 16 09:13:15 at
> java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1656)
> 9057Oct 16 09:13:15 at
> java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1594)
> 9058Oct 16 09:13:15 at
> java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:183)
> 9059Oct 16 09:13:15 Caused by: org.apache.flink.runtime.JobException:
> org.apache.flink.runtime.JobException: Recovery is suppressed by
> FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=10,
> backoffTimeMS=0)
> 9060Oct 16 09:13:15 at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:176)
> 9061Oct 16 09:13:15 at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:107)
> 9062Oct 16 09:13:15 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:285)
> 9063Oct 16 09:13:15 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:276)
> 9064Oct 16 09:13:15 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:269)
> 9065Oct 16 09:13:15 at
> org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:765)
> 9066Oct 16 09:13:15 at
> org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:742)
> 9067Oct 16 09:13:15 at
> org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
> 9068Oct 16 09:13:15 at
> org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1645)
> 9069Oct 16 09:13:15 at
> org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1144)
> 9070Oct 16 09:13:15 at
> org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1084)
> 9071Oct 16 09:13:15 at
> org.apache.flink.runtime.executiongraph.Execution.markFailed(Execution.java:923)
> 9072Oct 16 09:13:15 at
> org.apache.flink.runtime.scheduler.DefaultExecutionOperations.markFailed(DefaultExecutionOperations.java:43)
> 9073Oct 16 09:13:15 at
> org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.handleTaskDeploymentFailure(DefaultExecutionDeployer.java:330)
> 9074Oct 16 09:13:15 at
> org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.lambda$assignAllResourcesAndRegisterProducedPartitions$2(DefaultExecutionDeployer.java:169)
> 9075Oct 16 09:13:15 at
> java.base/java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:930)
> 9076Oct 16 09:13:15 at
> java.base/java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:907)
> 9077Oct 16 09:13:15 at
> java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506)
> 9078Oct 16 09:13:15 at
> java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2088)
> 9079Oct 16 09:13:15 at
> org.apache.flink.runtime.jobmaster.slotpool.PendingRequest.failRequest(PendingRequest.java:88)
> 9080Oct 16 09:13:15 at
> org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.releaseSlot(DeclarativeSlotPoolBridge.java:371)
> 9081Oct 16 09:13:15 at
> org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.timeoutPendingSlotRequest(DeclarativeSlotPoolBridge.java:342)
> 9082Oct 16 09:13:15 at
> org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.checkBatchSlotTimeout(DeclarativeSlotPoolBridge.java:497)
> 9083Oct 16 09:13:15 at
> java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
> 9084Oct 16 09:13:15 at
> java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
> 9085Oct 16 09:13:15 at
> org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRunAsync$4(PekkoRpcActor.java:451)
> 9086Oct 16 09:13:15 at
> org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
> 9087Oct 16 09:13:15 at
> org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRunAsync(PekkoRpcActor.java:451)
> 9088Oct 16 09:13:15 at
> org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:218)
> 9089Oct 16 09:13:15 at
> org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:85)
> 9090Oct 16 09:13:15 at
> org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:168)
> 9091Oct 16 09:13:15 at
> org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
> 9092Oct 16 09:13:15 at
> org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29)
> 9093Oct 16 09:13:15 at
> scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
> 9094Oct 16 09:13:15 at
> scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
> 9095Oct 16 09:13:15 at
> org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29)
> 9096Oct 16 09:13:15 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
> 9097Oct 16 09:13:15 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
> 9098Oct 16 09:13:15 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
> 9099Oct 16 09:13:15 at
> org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
> 9100Oct 16 09:13:15 at
> org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
> 9101Oct 16 09:13:15 at
> org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
> 9102Oct 16 09:13:15 at
> org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
> 9103Oct 16 09:13:15 at
> org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
> 9104Oct 16 09:13:15 at
> org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:280)
> 9105Oct 16 09:13:15 at
> org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:241)
> 9106Oct 16 09:13:15 at
> org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:253)
> 9107Oct 16 09:13:15 ... 5 more
> 9108Oct 16 09:13:15 Caused by: java.util.concurrent.CompletionException:
> java.util.concurrent.CompletionException:
> java.util.concurrent.CompletionException:
> org.apache.flink.util.FlinkException: Pending slot request with
> SlotRequestId{9204458405f867d3ac077179bf43a756} has been released.
> 9109Oct 16 09:13:15 at
> org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.lambda$assignResource$4(DefaultExecutionDeployer.java:226)
> 9110Oct 16 09:13:15 ... 37 more
> 9111Oct 16 09:13:15 Caused by: java.util.concurrent.CompletionException:
> java.util.concurrent.CompletionException:
> org.apache.flink.util.FlinkException: Pending slot request with
> SlotRequestId{9204458405f867d3ac077179bf43a756} has been released.
> 9112Oct 16 09:13:15 at
> java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:331)
> 9113Oct 16 09:13:15 at
> java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:346)
> 9114Oct 16 09:13:15 at
> java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:632)
> 9115Oct 16 09:13:15 ... 35 more
> 9116Oct 16 09:13:15 Caused by: org.apache.flink.util.FlinkException:
> org.apache.flink.util.FlinkException: Pending slot request with
> SlotRequestId{9204458405f867d3ac077179bf43a756} has been released.
> 9117Oct 16 09:13:15 at
> org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.releaseSlot(DeclarativeSlotPoolBridge.java:373)
> 9118Oct 16 09:13:15 ... 31 more
> 9119Oct 16 09:13:15 Caused by: java.util.concurrent.TimeoutException:
> java.util.concurrent.TimeoutException: Pending slot request timed out in slot
> pool.
> 9120Oct 16 09:13:15 ... 31 more{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
