[FLINK-33280] tests stage: HybridShuffleITCase.testHybridSelectiveExchangesRestart due to timeout

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.19.0
• Fix Version/s: 1.19.0
• Component/s: Runtime / Network
• Labels: github-actions test-stability
• Assignee: Unassigned
• Reporter: Matthias Pohl
• Created: 16/Oct/23 09:17
• Updated: 31/Oct/23 10:49
• Resolved: 18/Oct/23 12:09

Description

https://github.com/XComp/flink/actions/runs/6529754573/job/17728223099#step:12:9120

 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

Issue Links

• duplicates: FLINK-33185 HybridShuffleITCase fails with TimeoutException: Pending slot request timed out in slot pool on AZP