[
https://issues.apache.org/jira/browse/FLINK-29006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17585116#comment-17585116
]
Yufan Sheng commented on FLINK-29006:
-------------------------------------
[~renqs] I have checked the log. It seems like the root cause is . Can you help
me on this? I don't know why we would meet this exception.
{code:java}
01:55:15,929 [ Checkpoint Timer] INFO
org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to
trigger checkpoint for job 87a23d1ed0c3bcc081bc99e584c15b6e since Checkpoint
triggering task Source: Tested Source (1/4) of job
87a23d1ed0c3bcc081bc99e584c15b6e is not being executed at the moment. Aborting
checkpoint. Failure reason: Not all required tasks are currently running..
01:55:15,957 [flink-akka.actor.default-dispatcher-17] WARN
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager []
- Could not fulfill resource requirements of job
87a23d1ed0c3bcc081bc99e584c15b6e. Free slots: 0
01:55:15,958 [flink-akka.actor.default-dispatcher-17] WARN
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge [] -
Could not acquire the minimum required resources, failing slot requests.
Acquired:
[ResourceRequirement{resourceProfile=ResourceProfile{taskHeapMemory=170.667gb
(183251937962 bytes), taskOffHeapMemory=170.667gb (183251937962 bytes),
managedMemory=13.333mb (13981013 bytes), networkMemory=10.667mb (11184810
bytes)}, numberOfRequiredSlots=2}]. Current slot pool status: Registered TMs:
1, registered slots: 2 free slots: 0
01:55:15,962 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Tested Source (2/4) (b0e672230eb11a915c4a9e2107ae924f) switched from SCHEDULED
to FAILED on [unassigned resource].
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
01:55:15,968 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution b0e672230eb11a915c4a9e2107ae924f.
01:55:15,969 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy
[] - Calculating tasks to restart to recover the failed task
bc764cd8ddf7a0cff126f51c16239658_1.
01:55:15,969 [SourceCoordinator-Source: Tested Source] INFO
org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing
registered reader after failure for subtask 1 of source Source: Tested Source.
01:55:15,970 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy
[] - 5 tasks should be restarted to recover the failed task
bc764cd8ddf7a0cff126f51c16239658_1.
01:55:15,973 [ Checkpoint Timer] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering
checkpoint 4781 (type=CheckpointType{name='Checkpoint',
sharingFilesStrategy=FORWARD_BACKWARD}) @ 1660701315973 for job
0769e011a959775468a874599b9a6f09.
01:55:15,973 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Restart
Test (87a23d1ed0c3bcc081bc99e584c15b6e) switched from state RUNNING to FAILING.
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:739)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1536)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1118)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1058)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.markFailed(Execution.java:897)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.ExecutionVertex.markFailed(ExecutionVertex.java:466)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultExecutionVertexOperations.markFailed(DefaultExecutionVertexOperations.java:42)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskDeploymentFailure(DefaultScheduler.java:658)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.lambda$assignAllResourcesAndRegisterProducedPartitions$6(DefaultScheduler.java:530)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
~[?:1.8.0_292]
at
org.apache.flink.runtime.jobmaster.slotpool.PendingRequest.failRequest(PendingRequest.java:88)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.cancelPendingRequests(DeclarativeSlotPoolBridge.java:186)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.failPendingRequests(DeclarativeSlotPoolBridge.java:408)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.notifyNotEnoughResourcesAvailable(DeclarativeSlotPoolBridge.java:397)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.JobMaster.notifyNotEnoughResourcesAvailable(JobMaster.java:859)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_292]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_292]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_292]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_292]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$0(AkkaRpcActor.java:296)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:295)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.actor.Actor.aroundReceive(Actor.scala:537)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.actor.Actor.aroundReceive$(Actor.scala:535)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.actor.ActorCell.invoke(ActorCell.scala:548)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.run(Mailbox.scala:231)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
[?:1.8.0_292]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[?:1.8.0_292]
Caused by: java.util.concurrent.CompletionException:
java.util.concurrent.CompletionException:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
at
org.apache.flink.runtime.scheduler.DefaultScheduler.lambda$assignResource$8(DefaultScheduler.java:588)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
... 39 more
Caused by: java.util.concurrent.CompletionException:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
~[?:1.8.0_292]
... 37 more
Caused by:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
01:55:15,977 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Tested Source (1/4) (f040702ad41cd88fae0f96b06e514cc1) switched from SCHEDULED
to CANCELING.
01:55:15,977 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Tested Source (1/4) (f040702ad41cd88fae0f96b06e514cc1) switched from CANCELING
to CANCELED.
01:55:15,977 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution f040702ad41cd88fae0f96b06e514cc1.
01:55:15,978 [jobmanager-io-thread-12] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Completed
checkpoint 4781 for job 0769e011a959775468a874599b9a6f09 (2807 bytes,
checkpointDuration=5 ms, finalizationTime=0 ms).
01:55:15,978 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution f040702ad41cd88fae0f96b06e514cc1.
01:55:15,978 [SourceCoordinator-Source: Tested Source] INFO
org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Marking
checkpoint 4781 as completed for source Source: Tested Source.
01:55:15,978 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Tested Source (3/4) (cfccc425f53da834665067f00def3ca2) switched from SCHEDULED
to CANCELING.
01:55:15,978 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Tested Source (3/4) (cfccc425f53da834665067f00def3ca2) switched from CANCELING
to CANCELED.
01:55:15,978 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution cfccc425f53da834665067f00def3ca2.
01:55:15,978 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution cfccc425f53da834665067f00def3ca2.
01:55:15,978 [flink-akka.actor.default-dispatcher-29] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager []
- Received resource requirements from job 87a23d1ed0c3bcc081bc99e584c15b6e:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=3}]
01:55:15,979 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Tested Source (4/4) (2d46baa77ad010d5f7ba937fdba6333a) switched from SCHEDULED
to CANCELING.
01:55:15,979 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Tested Source (4/4) (2d46baa77ad010d5f7ba937fdba6333a) switched from CANCELING
to CANCELED.
01:55:15,979 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 2d46baa77ad010d5f7ba937fdba6333a.
01:55:15,979 [flink-akka.actor.default-dispatcher-29] WARN
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager []
- Could not fulfill resource requirements of job
87a23d1ed0c3bcc081bc99e584c15b6e. Free slots: 0
01:55:15,979 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Sink: Data
stream collect sink (1/1) (1b7bfdf3bef9c6cf69f7a0ca81747b30) switched from
SCHEDULED to CANCELING.
01:55:15,979 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Sink: Data
stream collect sink (1/1) (1b7bfdf3bef9c6cf69f7a0ca81747b30) switched from
CANCELING to CANCELED.
01:55:15,979 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 1b7bfdf3bef9c6cf69f7a0ca81747b30.
01:55:15,979 [flink-akka.actor.default-dispatcher-27] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager []
- Received resource requirements from job 87a23d1ed0c3bcc081bc99e584c15b6e:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=2}]
01:55:15,982 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Restart
Test (87a23d1ed0c3bcc081bc99e584c15b6e) switched from state FAILING to FAILED.
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:739)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1536)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1118)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1058)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.markFailed(Execution.java:897)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.ExecutionVertex.markFailed(ExecutionVertex.java:466)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultExecutionVertexOperations.markFailed(DefaultExecutionVertexOperations.java:42)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskDeploymentFailure(DefaultScheduler.java:658)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.lambda$assignAllResourcesAndRegisterProducedPartitions$6(DefaultScheduler.java:530)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
~[?:1.8.0_292]
at
org.apache.flink.runtime.jobmaster.slotpool.PendingRequest.failRequest(PendingRequest.java:88)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.cancelPendingRequests(DeclarativeSlotPoolBridge.java:186)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.failPendingRequests(DeclarativeSlotPoolBridge.java:408)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.notifyNotEnoughResourcesAvailable(DeclarativeSlotPoolBridge.java:397)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.JobMaster.notifyNotEnoughResourcesAvailable(JobMaster.java:859)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_292]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_292]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_292]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_292]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$0(AkkaRpcActor.java:296)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:295)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
~[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.actor.Actor.aroundReceive(Actor.scala:537)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.actor.Actor.aroundReceive$(Actor.scala:535)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.actor.ActorCell.invoke(ActorCell.scala:548)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.run(Mailbox.scala:231)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
[flink-rpc-akka_462109a1-47d8-42e1-a010-a87419fdc33d.jar:1.15-SNAPSHOT]
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
[?:1.8.0_292]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[?:1.8.0_292]
Caused by: java.util.concurrent.CompletionException:
java.util.concurrent.CompletionException:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
at
org.apache.flink.runtime.scheduler.DefaultScheduler.lambda$assignResource$8(DefaultScheduler.java:588)
~[flink-runtime-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
... 39 more
Caused by: java.util.concurrent.CompletionException:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
~[?:1.8.0_292]
... 37 more
Caused by:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
01:55:15,982 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Stopping
checkpoint coordinator for job 87a23d1ed0c3bcc081bc99e584c15b6e.
01:55:15,989 [flink-akka.actor.default-dispatcher-27] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager []
- Clearing resource requirements of job 87a23d1ed0c3bcc081bc99e584c15b6e
01:55:15,995 [flink-akka.actor.default-dispatcher-29] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Job
87a23d1ed0c3bcc081bc99e584c15b6e reached terminal state FAILED.
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:739)
at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1536)
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1118)
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1058)
at
org.apache.flink.runtime.executiongraph.Execution.markFailed(Execution.java:897)
at
org.apache.flink.runtime.executiongraph.ExecutionVertex.markFailed(ExecutionVertex.java:466)
at
org.apache.flink.runtime.scheduler.DefaultExecutionVertexOperations.markFailed(DefaultExecutionVertexOperations.java:42)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskDeploymentFailure(DefaultScheduler.java:658)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.lambda$assignAllResourcesAndRegisterProducedPartitions$6(DefaultScheduler.java:530)
at
java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
at
java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
at
java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
at
java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
at
org.apache.flink.runtime.jobmaster.slotpool.PendingRequest.failRequest(PendingRequest.java:88)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.cancelPendingRequests(DeclarativeSlotPoolBridge.java:186)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.failPendingRequests(DeclarativeSlotPoolBridge.java:408)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.notifyNotEnoughResourcesAvailable(DeclarativeSlotPoolBridge.java:397)
at
org.apache.flink.runtime.jobmaster.JobMaster.notifyNotEnoughResourcesAvailable(JobMaster.java:859)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$0(AkkaRpcActor.java:296)
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:295)
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
at akka.actor.Actor.aroundReceive(Actor.scala:537)
at akka.actor.Actor.aroundReceive$(Actor.scala:535)
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
at akka.actor.ActorCell.invoke(ActorCell.scala:548)
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
at akka.dispatch.Mailbox.run(Mailbox.scala:231)
at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
Caused by: java.util.concurrent.CompletionException:
java.util.concurrent.CompletionException:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
at
org.apache.flink.runtime.scheduler.DefaultScheduler.lambda$assignResource$8(DefaultScheduler.java:588)
... 39 more
Caused by: java.util.concurrent.CompletionException:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
at
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607)
at
java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
... 37 more
Caused by:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
01:55:15,996 [mini-cluster-io-thread-2] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Job
87a23d1ed0c3bcc081bc99e584c15b6e has been registered for cleanup in the
JobResultStore after reaching a terminal state.
01:55:15,996 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Stopping the
JobMaster for job 'Restart Test' (87a23d1ed0c3bcc081bc99e584c15b6e).
01:55:15,998 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool [] -
Releasing slot [87c97990e80f8864a5118945e53d9bd2].
01:55:15,998 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool [] -
Releasing slot [ae2fd247ef273b8c211b7a5be489b735].
01:55:15,998 [flink-akka.actor.default-dispatcher-17] INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Close
ResourceManager connection 0c328f02b8c145b207e5cec7a3f6e6e3: Stopping JobMaster
for job 'Restart Test' (87a23d1ed0c3bcc081bc99e584c15b6e).
01:55:15,997 [ Thread-12] INFO
org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Closing
SourceCoordinator for source Source: Tested Source.
01:55:16,000 [flink-akka.actor.default-dispatcher-27] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
Disconnect job manager
b89d246bb6af7e8ff698a66e2d694...@akka.tcp://flink@localhost:39292/user/rpc/jobmanager_6
for job 87a23d1ed0c3bcc081bc99e584c15b6e from the resource manager.
01:55:16,002 [mini-cluster-io-thread-1] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - JobManager
for job 87a23d1ed0c3bcc081bc99e584c15b6e with leader id
b89d246bb6af7e8ff698a66e2d6940df lost leadership.
01:55:16,002 [flink-akka.actor.default-dispatcher-27] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:1, state:ACTIVE, resource profile:
ResourceProfile{taskHeapMemory=170.667gb (183251937962 bytes),
taskOffHeapMemory=170.667gb (183251937962 bytes), managedMemory=13.333mb
(13981013 bytes), networkMemory=10.667mb (11184810 bytes)}, allocationId:
87c97990e80f8864a5118945e53d9bd2, jobId: 87a23d1ed0c3bcc081bc99e584c15b6e).
01:55:16,003 [flink-akka.actor.default-dispatcher-27] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:2, state:ACTIVE, resource profile:
ResourceProfile{taskHeapMemory=170.667gb (183251937962 bytes),
taskOffHeapMemory=170.667gb (183251937962 bytes), managedMemory=13.333mb
(13981013 bytes), networkMemory=10.667mb (11184810 bytes)}, allocationId:
ae2fd247ef273b8c211b7a5be489b735, jobId: 87a23d1ed0c3bcc081bc99e584c15b6e).
01:55:16,003 [flink-akka.actor.default-dispatcher-27] INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Remove job
87a23d1ed0c3bcc081bc99e584c15b6e from job leader monitoring.
01:55:16,003 [flink-akka.actor.default-dispatcher-27] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Close
JobManager connection for job 87a23d1ed0c3bcc081bc99e584c15b6e.
01:55:16,054 [ Checkpoint Timer] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering
checkpoint 4782 (type=CheckpointType{name='Checkpoint',
sharingFilesStrategy=FORWARD_BACKWARD}) @ 1660701316024 for job
0769e011a959775468a874599b9a6f09.
01:55:16,054 [ Thread-12] INFO
org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source
coordinator for source Source: Tested Source closed.
01:55:16,055 [ main] ERROR
org.apache.flink.util.TestLoggerExtension [] -
{code}
> PulsarSourceITCase failed with Could not acquire the minimum required
> resources.
> --------------------------------------------------------------------------------
>
> Key: FLINK-29006
> URL: https://issues.apache.org/jira/browse/FLINK-29006
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.15.1
> Reporter: Huang Xingbo
> Priority: Critical
> Labels: test-stability
>
> {code:java}
> 2022-08-17T01:58:54.4397238Z Aug 17 01:58:54 [ERROR]
> PulsarSourceITCase>SourceTestSuiteBase.testScaleDown:280->SourceTestSuiteBase.restartFromSavepoint:330->SourceTestSuiteBase.checkResultWithSemantic:744
>
> 2022-08-17T01:58:54.4397969Z Aug 17 01:58:54 Expecting
> 2022-08-17T01:58:54.4398407Z Aug 17 01:58:54 <CompletableFuture[Failed with
> the following stack trace:
> 2022-08-17T01:58:54.4399009Z Aug 17 01:58:54 java.lang.RuntimeException:
> Failed to fetch next result
> 2022-08-17T01:58:54.4399720Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
> 2022-08-17T01:58:54.4400608Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
> 2022-08-17T01:58:54.4401505Z Aug 17 01:58:54 at
> org.apache.flink.connector.testframe.utils.CollectIteratorAssert.compareWithExactlyOnceSemantic(CollectIteratorAssert.java:116)
> 2022-08-17T01:58:54.4402417Z Aug 17 01:58:54 at
> org.apache.flink.connector.testframe.utils.CollectIteratorAssert.matchesRecordsFromSource(CollectIteratorAssert.java:71)
> 2022-08-17T01:58:54.4403459Z Aug 17 01:58:54 at
> org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.lambda$checkResultWithSemantic$3(SourceTestSuiteBase.java:741)
> 2022-08-17T01:58:54.4404435Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
> 2022-08-17T01:58:54.4405324Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$AsyncSupply.exec(CompletableFuture.java:1596)
> 2022-08-17T01:58:54.4406006Z Aug 17 01:58:54 at
> java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
> 2022-08-17T01:58:54.4406645Z Aug 17 01:58:54 at
> java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
> 2022-08-17T01:58:54.4407305Z Aug 17 01:58:54 at
> java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
> 2022-08-17T01:58:54.4407974Z Aug 17 01:58:54 at
> java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
> 2022-08-17T01:58:54.4408686Z Aug 17 01:58:54 Caused by: java.io.IOException:
> Failed to fetch job execution result
> 2022-08-17T01:58:54.4409432Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184)
> 2022-08-17T01:58:54.4410300Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121)
> 2022-08-17T01:58:54.4411158Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
> 2022-08-17T01:58:54.4411842Z Aug 17 01:58:54 ... 10 more
> 2022-08-17T01:58:54.4412708Z Aug 17 01:58:54 Caused by:
> java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2022-08-17T01:58:54.4413686Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2022-08-17T01:58:54.4414572Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
> 2022-08-17T01:58:54.4415394Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182)
> 2022-08-17T01:58:54.4416024Z Aug 17 01:58:54 ... 12 more
> 2022-08-17T01:58:54.4416508Z Aug 17 01:58:54 Caused by:
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2022-08-17T01:58:54.4417327Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
> 2022-08-17T01:58:54.4418138Z Aug 17 01:58:54 at
> org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
> 2022-08-17T01:58:54.4419016Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
> 2022-08-17T01:58:54.4419715Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
> 2022-08-17T01:58:54.4420429Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-08-17T01:58:54.4421102Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2022-08-17T01:58:54.4421861Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:259)
> 2022-08-17T01:58:54.4422636Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2022-08-17T01:58:54.4423369Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2022-08-17T01:58:54.4424094Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-08-17T01:58:54.4425089Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2022-08-17T01:58:54.4425789Z Aug 17 01:58:54 at
> org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389)
> 2022-08-17T01:58:54.4426688Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
> 2022-08-17T01:58:54.4427515Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
> 2022-08-17T01:58:54.4428419Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
> 2022-08-17T01:58:54.4429329Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2022-08-17T01:58:54.4430067Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2022-08-17T01:58:54.4430794Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-08-17T01:58:54.4431489Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2022-08-17T01:58:54.4432210Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47)
> 2022-08-17T01:58:54.4432881Z Aug 17 01:58:54 at
> akka.dispatch.OnComplete.internal(Future.scala:300)
> 2022-08-17T01:58:54.4433451Z Aug 17 01:58:54 at
> akka.dispatch.OnComplete.internal(Future.scala:297)
> 2022-08-17T01:58:54.4434037Z Aug 17 01:58:54 at
> akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
> 2022-08-17T01:58:54.4434896Z Aug 17 01:58:54 at
> akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
> 2022-08-17T01:58:54.4435505Z Aug 17 01:58:54 at
> scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
> 2022-08-17T01:58:54.4436223Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
> 2022-08-17T01:58:54.4436996Z Aug 17 01:58:54 at
> scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
> 2022-08-17T01:58:54.4437709Z Aug 17 01:58:54 at
> scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
> 2022-08-17T01:58:54.4438463Z Aug 17 01:58:54 at
> scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
> 2022-08-17T01:58:54.4439247Z Aug 17 01:58:54 at
> scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
> 2022-08-17T01:58:54.4439895Z Aug 17 01:58:54 at
> akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
> 2022-08-17T01:58:54.4440623Z Aug 17 01:58:54 at
> akka.remote.DefaultMessageDispatcher.dispatch(Endpoint.scala:118)
> 2022-08-17T01:58:54.4441277Z Aug 17 01:58:54 at
> akka.remote.EndpointReader$$anonfun$receive$2.applyOrElse(Endpoint.scala:1144)
> 2022-08-17T01:58:54.4441911Z Aug 17 01:58:54 at
> akka.actor.Actor.aroundReceive(Actor.scala:537)
> 2022-08-17T01:58:54.4442472Z Aug 17 01:58:54 at
> akka.actor.Actor.aroundReceive$(Actor.scala:535)
> 2022-08-17T01:58:54.4443053Z Aug 17 01:58:54 at
> akka.remote.EndpointActor.aroundReceive(Endpoint.scala:540)
> 2022-08-17T01:58:54.4443663Z Aug 17 01:58:54 at
> akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
> 2022-08-17T01:58:54.4444342Z Aug 17 01:58:54 at
> akka.actor.ActorCell.invoke(ActorCell.scala:548)
> 2022-08-17T01:58:54.4445037Z Aug 17 01:58:54 at
> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
> 2022-08-17T01:58:54.4445606Z Aug 17 01:58:54 at
> akka.dispatch.Mailbox.run(Mailbox.scala:231)
> 2022-08-17T01:58:54.4446152Z Aug 17 01:58:54 at
> akka.dispatch.Mailbox.exec(Mailbox.scala:243)
> 2022-08-17T01:58:54.4446593Z Aug 17 01:58:54 ... 4 more
> 2022-08-17T01:58:54.4447124Z Aug 17 01:58:54 Caused by:
> org.apache.flink.runtime.JobException: Recovery is suppressed by
> NoRestartBackoffTimeStrategy
> 2022-08-17T01:58:54.4447945Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
> 2022-08-17T01:58:54.4449004Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
> 2022-08-17T01:58:54.4449973Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
> 2022-08-17T01:58:54.4450764Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
> 2022-08-17T01:58:54.4451597Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
> 2022-08-17T01:58:54.4452420Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:739)
> 2022-08-17T01:58:54.4453338Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
> 2022-08-17T01:58:54.4454496Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1536)
> 2022-08-17T01:58:54.4455459Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1118)
> 2022-08-17T01:58:54.4456158Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1058)
> 2022-08-17T01:58:54.4456871Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.Execution.markFailed(Execution.java:897)
> 2022-08-17T01:58:54.4457615Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.ExecutionVertex.markFailed(ExecutionVertex.java:466)
> 2022-08-17T01:58:54.4458441Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultExecutionVertexOperations.markFailed(DefaultExecutionVertexOperations.java:42)
> 2022-08-17T01:58:54.4459355Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskDeploymentFailure(DefaultScheduler.java:658)
> 2022-08-17T01:58:54.4460245Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.lambda$assignAllResourcesAndRegisterProducedPartitions$6(DefaultScheduler.java:530)
> 2022-08-17T01:58:54.4461076Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
> 2022-08-17T01:58:54.4461768Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
> 2022-08-17T01:58:54.4462478Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-08-17T01:58:54.4463316Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> 2022-08-17T01:58:54.4464075Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.slotpool.PendingRequest.failRequest(PendingRequest.java:88)
> 2022-08-17T01:58:54.4465126Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.cancelPendingRequests(DeclarativeSlotPoolBridge.java:186)
> 2022-08-17T01:58:54.4466052Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.failPendingRequests(DeclarativeSlotPoolBridge.java:408)
> 2022-08-17T01:58:54.4467009Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.notifyNotEnoughResourcesAvailable(DeclarativeSlotPoolBridge.java:397)
> 2022-08-17T01:58:54.4467882Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.JobMaster.notifyNotEnoughResourcesAvailable(JobMaster.java:859)
> 2022-08-17T01:58:54.4468633Z Aug 17 01:58:54 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-08-17T01:58:54.4469265Z Aug 17 01:58:54 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-08-17T01:58:54.4469982Z Aug 17 01:58:54 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-08-17T01:58:54.4470627Z Aug 17 01:58:54 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-08-17T01:58:54.4471311Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$0(AkkaRpcActor.java:296)
> 2022-08-17T01:58:54.4472257Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
> 2022-08-17T01:58:54.4473044Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:295)
> 2022-08-17T01:58:54.4473804Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
> 2022-08-17T01:58:54.4474895Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
> 2022-08-17T01:58:54.4475685Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
> 2022-08-17T01:58:54.4476361Z Aug 17 01:58:54 at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
> 2022-08-17T01:58:54.4476987Z Aug 17 01:58:54 at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
> 2022-08-17T01:58:54.4477602Z Aug 17 01:58:54 at
> scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
> 2022-08-17T01:58:54.4478211Z Aug 17 01:58:54 at
> scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
> 2022-08-17T01:58:54.4478937Z Aug 17 01:58:54 at
> akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
> 2022-08-17T01:58:54.4479580Z Aug 17 01:58:54 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
> 2022-08-17T01:58:54.4480219Z Aug 17 01:58:54 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> 2022-08-17T01:58:54.4480864Z Aug 17 01:58:54 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> 2022-08-17T01:58:54.4481462Z Aug 17 01:58:54 at
> akka.actor.Actor.aroundReceive(Actor.scala:537)
> 2022-08-17T01:58:54.4482006Z Aug 17 01:58:54 at
> akka.actor.Actor.aroundReceive$(Actor.scala:535)
> 2022-08-17T01:58:54.4482603Z Aug 17 01:58:54 at
> akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
> 2022-08-17T01:58:54.4483096Z Aug 17 01:58:54 ... 9 more
> 2022-08-17T01:58:54.4483848Z Aug 17 01:58:54 Caused by:
> java.util.concurrent.CompletionException:
> java.util.concurrent.CompletionException:
> org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
> Could not acquire the minimum required resources.
> 2022-08-17T01:58:54.4484945Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.lambda$assignResource$8(DefaultScheduler.java:588)
> 2022-08-17T01:58:54.4485528Z Aug 17 01:58:54 ... 39 more
> 2022-08-17T01:58:54.4486186Z Aug 17 01:58:54 Caused by:
> java.util.concurrent.CompletionException:
> org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
> Could not acquire the minimum required resources.
> 2022-08-17T01:58:54.4487210Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
> 2022-08-17T01:58:54.4487934Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
> 2022-08-17T01:58:54.4488699Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607)
> 2022-08-17T01:58:54.4489412Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
> 2022-08-17T01:58:54.4489941Z Aug 17 01:58:54 ... 37 more
> 2022-08-17T01:58:54.4490537Z Aug 17 01:58:54 Caused by:
> org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
> Could not acquire the minimum required resources.
> 2022-08-17T01:58:54.4491087Z Aug 17 01:58:54 ]>
> 2022-08-17T01:58:54.4491446Z Aug 17 01:58:54 to be completed within 2M.
> 2022-08-17T01:58:54.4491801Z Aug 17 01:58:54
> 2022-08-17T01:58:54.4492400Z Aug 17 01:58:54 exception caught while trying to
> get the future result: java.util.concurrent.ExecutionException:
> java.lang.RuntimeException: Failed to fetch next result
> 2022-08-17T01:58:54.4493183Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2022-08-17T01:58:54.4493858Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
> 2022-08-17T01:58:54.4494768Z Aug 17 01:58:54 at
> org.assertj.core.internal.Futures.assertSucceededWithin(Futures.java:109)
> 2022-08-17T01:58:54.4495691Z Aug 17 01:58:54 at
> org.assertj.core.api.AbstractCompletableFutureAssert.internalSucceedsWithin(AbstractCompletableFutureAssert.java:400)
> 2022-08-17T01:58:54.4496558Z Aug 17 01:58:54 at
> org.assertj.core.api.AbstractCompletableFutureAssert.succeedsWithin(AbstractCompletableFutureAssert.java:396)
> 2022-08-17T01:58:54.4497434Z Aug 17 01:58:54 at
> org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.checkResultWithSemantic(SourceTestSuiteBase.java:744)
> 2022-08-17T01:58:54.4498337Z Aug 17 01:58:54 at
> org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.restartFromSavepoint(SourceTestSuiteBase.java:330)
> 2022-08-17T01:58:54.4499276Z Aug 17 01:58:54 at
> org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.testScaleDown(SourceTestSuiteBase.java:280)
> 2022-08-17T01:58:54.4499981Z Aug 17 01:58:54 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-08-17T01:58:54.4500597Z Aug 17 01:58:54 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-08-17T01:58:54.4501310Z Aug 17 01:58:54 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-08-17T01:58:54.4501953Z Aug 17 01:58:54 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-08-17T01:58:54.4502601Z Aug 17 01:58:54 at
> org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)
> 2022-08-17T01:58:54.4503337Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
> 2022-08-17T01:58:54.4504176Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
> 2022-08-17T01:58:54.4505374Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
> 2022-08-17T01:58:54.4506142Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
> 2022-08-17T01:58:54.4506962Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
> 2022-08-17T01:58:54.4507840Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
> 2022-08-17T01:58:54.4509177Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
> 2022-08-17T01:58:54.4510181Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
> 2022-08-17T01:58:54.4511081Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
> 2022-08-17T01:58:54.4511926Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
> 2022-08-17T01:58:54.4512761Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
> 2022-08-17T01:58:54.4513547Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
> 2022-08-17T01:58:54.4514429Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
> 2022-08-17T01:58:54.4515347Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214)
> 2022-08-17T01:58:54.4516201Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2022-08-17T01:58:54.4517026Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210)
> 2022-08-17T01:58:54.4517862Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)
> 2022-08-17T01:58:54.4518883Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66)
> 2022-08-17T01:58:54.4519704Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
> 2022-08-17T01:58:54.4520533Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2022-08-17T01:58:54.4521367Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
> 2022-08-17T01:58:54.4522126Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2022-08-17T01:58:54.4522884Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
> 2022-08-17T01:58:54.4523709Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2022-08-17T01:58:54.4524617Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
> 2022-08-17T01:58:54.4525381Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
> 2022-08-17T01:58:54.4526265Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
> 2022-08-17T01:58:54.4527227Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:226)
> 2022-08-17T01:58:54.4528108Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:204)
> 2022-08-17T01:58:54.4529042Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:139)
> 2022-08-17T01:58:54.4529898Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:107)
> 2022-08-17T01:58:54.4530671Z Aug 17 01:58:54 at
> java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> 2022-08-17T01:58:54.4531347Z Aug 17 01:58:54 at
> java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> 2022-08-17T01:58:54.4532097Z Aug 17 01:58:54 at
> java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
> 2022-08-17T01:58:54.4532773Z Aug 17 01:58:54 at
> java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
> 2022-08-17T01:58:54.4533431Z Aug 17 01:58:54 at
> java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
> 2022-08-17T01:58:54.4534102Z Aug 17 01:58:54 at
> java.util.LinkedList$LLSpliterator.forEachRemaining(LinkedList.java:1235)
> 2022-08-17T01:58:54.4535174Z Aug 17 01:58:54 at
> java.util.stream.ReferencePipeline$Head.forEach(ReferencePipeline.java:647)
> 2022-08-17T01:58:54.4535863Z Aug 17 01:58:54 at
> java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
> 2022-08-17T01:58:54.4536535Z Aug 17 01:58:54 at
> java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
> 2022-08-17T01:58:54.4537218Z Aug 17 01:58:54 at
> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
> 2022-08-17T01:58:54.4537891Z Aug 17 01:58:54 at
> java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
> 2022-08-17T01:58:54.4538645Z Aug 17 01:58:54 at
> java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
> 2022-08-17T01:58:54.4539354Z Aug 17 01:58:54 at
> java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
> 2022-08-17T01:58:54.4540036Z Aug 17 01:58:54 at
> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> 2022-08-17T01:58:54.4540676Z Aug 17 01:58:54 at
> java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
> 2022-08-17T01:58:54.4541450Z Aug 17 01:58:54 at
> java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
> 2022-08-17T01:58:54.4542136Z Aug 17 01:58:54 at
> java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
> 2022-08-17T01:58:54.4542815Z Aug 17 01:58:54 at
> java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
> 2022-08-17T01:58:54.4543487Z Aug 17 01:58:54 at
> java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
> 2022-08-17T01:58:54.4544183Z Aug 17 01:58:54 at
> java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
> 2022-08-17T01:58:54.4545092Z Aug 17 01:58:54 at
> java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
> 2022-08-17T01:58:54.4545773Z Aug 17 01:58:54 at
> java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
> 2022-08-17T01:58:54.4546427Z Aug 17 01:58:54 at
> java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
> 2022-08-17T01:58:54.4547180Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:107)
> 2022-08-17T01:58:54.4548007Z Aug 17 01:58:54 at
> org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:42)
> 2022-08-17T01:58:54.4548924Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
> 2022-08-17T01:58:54.4549757Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2022-08-17T01:58:54.4550826Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
> 2022-08-17T01:58:54.4551571Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2022-08-17T01:58:54.4552332Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
> 2022-08-17T01:58:54.4553165Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2022-08-17T01:58:54.4553969Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
> 2022-08-17T01:58:54.4555019Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
> 2022-08-17T01:58:54.4555796Z Aug 17 01:58:54 at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2022-08-17T01:58:54.4556597Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
> 2022-08-17T01:58:54.4557528Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
> 2022-08-17T01:58:54.4558352Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2022-08-17T01:58:54.4559262Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
> 2022-08-17T01:58:54.4560019Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2022-08-17T01:58:54.4560778Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
> 2022-08-17T01:58:54.4561602Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2022-08-17T01:58:54.4562401Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
> 2022-08-17T01:58:54.4563159Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
> 2022-08-17T01:58:54.4563810Z Aug 17 01:58:54 at
> java.util.ArrayList.forEach(ArrayList.java:1259)
> 2022-08-17T01:58:54.4564797Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
> 2022-08-17T01:58:54.4565740Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
> 2022-08-17T01:58:54.4566558Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2022-08-17T01:58:54.4567384Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
> 2022-08-17T01:58:54.4568138Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
> 2022-08-17T01:58:54.4568968Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
> 2022-08-17T01:58:54.4569770Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
> 2022-08-17T01:58:54.4570573Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
> 2022-08-17T01:58:54.4571344Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
> 2022-08-17T01:58:54.4572234Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
> 2022-08-17T01:58:54.4573180Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
> 2022-08-17T01:58:54.4574028Z Aug 17 01:58:54 at
> org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
> 2022-08-17T01:58:54.4575150Z Aug 17 01:58:54 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2022-08-17T01:58:54.4575968Z Aug 17 01:58:54 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2022-08-17T01:58:54.4576813Z Aug 17 01:58:54 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2022-08-17T01:58:54.4577692Z Aug 17 01:58:54 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2022-08-17T01:58:54.4578720Z Aug 17 01:58:54 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2022-08-17T01:58:54.4579499Z Aug 17 01:58:54 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2022-08-17T01:58:54.4580215Z Aug 17 01:58:54 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2022-08-17T01:58:54.4581008Z Aug 17 01:58:54 at
> org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2022-08-17T01:58:54.4581848Z Aug 17 01:58:54 at
> org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2022-08-17T01:58:54.4582638Z Aug 17 01:58:54 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2022-08-17T01:58:54.4583461Z Aug 17 01:58:54 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2022-08-17T01:58:54.4584394Z Aug 17 01:58:54 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
> 2022-08-17T01:58:54.4585246Z Aug 17 01:58:54 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2022-08-17T01:58:54.4585968Z Aug 17 01:58:54 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2022-08-17T01:58:54.4586645Z Aug 17 01:58:54 at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2022-08-17T01:58:54.4587406Z Aug 17 01:58:54 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> 2022-08-17T01:58:54.4588007Z Aug 17 01:58:54 Caused by:
> java.lang.RuntimeException: Failed to fetch next result
> 2022-08-17T01:58:54.4588858Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
> 2022-08-17T01:58:54.4589748Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
> 2022-08-17T01:58:54.4590639Z Aug 17 01:58:54 at
> org.apache.flink.connector.testframe.utils.CollectIteratorAssert.compareWithExactlyOnceSemantic(CollectIteratorAssert.java:116)
> 2022-08-17T01:58:54.4591555Z Aug 17 01:58:54 at
> org.apache.flink.connector.testframe.utils.CollectIteratorAssert.matchesRecordsFromSource(CollectIteratorAssert.java:71)
> 2022-08-17T01:58:54.4592474Z Aug 17 01:58:54 at
> org.apache.flink.connector.testframe.testsuites.SourceTestSuiteBase.lambda$checkResultWithSemantic$3(SourceTestSuiteBase.java:741)
> 2022-08-17T01:58:54.4593308Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1604)
> 2022-08-17T01:58:54.4594015Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$AsyncSupply.exec(CompletableFuture.java:1596)
> 2022-08-17T01:58:54.4594913Z Aug 17 01:58:54 at
> java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
> 2022-08-17T01:58:54.4595582Z Aug 17 01:58:54 at
> java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
> 2022-08-17T01:58:54.4596247Z Aug 17 01:58:54 at
> java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
> 2022-08-17T01:58:54.4596912Z Aug 17 01:58:54 at
> java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
> 2022-08-17T01:58:54.4597531Z Aug 17 01:58:54 Caused by: java.io.IOException:
> Failed to fetch job execution result
> 2022-08-17T01:58:54.4598270Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184)
> 2022-08-17T01:58:54.4599199Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121)
> 2022-08-17T01:58:54.4600068Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
> 2022-08-17T01:58:54.4600798Z Aug 17 01:58:54 ... 10 more
> 2022-08-17T01:58:54.4601382Z Aug 17 01:58:54 Caused by:
> java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2022-08-17T01:58:54.4602126Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2022-08-17T01:58:54.4602796Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
> 2022-08-17T01:58:54.4603567Z Aug 17 01:58:54 at
> org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182)
> 2022-08-17T01:58:54.4604198Z Aug 17 01:58:54 ... 12 more
> 2022-08-17T01:58:54.4604783Z Aug 17 01:58:54 Caused by:
> org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
> 2022-08-17T01:58:54.4605466Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
> 2022-08-17T01:58:54.4606280Z Aug 17 01:58:54 at
> org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
> 2022-08-17T01:58:54.4607071Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
> 2022-08-17T01:58:54.4607770Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
> 2022-08-17T01:58:54.4608462Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-08-17T01:58:54.4609214Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2022-08-17T01:58:54.4610055Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$1(AkkaInvocationHandler.java:259)
> 2022-08-17T01:58:54.4610826Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2022-08-17T01:58:54.4611558Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2022-08-17T01:58:54.4612285Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-08-17T01:58:54.4612973Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2022-08-17T01:58:54.4613898Z Aug 17 01:58:54 at
> org.apache.flink.util.concurrent.FutureUtils.doForward(FutureUtils.java:1389)
> 2022-08-17T01:58:54.4614875Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$null$1(ClassLoadingUtils.java:93)
> 2022-08-17T01:58:54.4615725Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
> 2022-08-17T01:58:54.4616627Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$guardCompletionWithContextClassLoader$2(ClassLoadingUtils.java:92)
> 2022-08-17T01:58:54.4617628Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2022-08-17T01:58:54.4618562Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2022-08-17T01:58:54.4619292Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-08-17T01:58:54.4619969Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
> 2022-08-17T01:58:54.4620699Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$1.onComplete(AkkaFutureUtils.java:47)
> 2022-08-17T01:58:54.4621372Z Aug 17 01:58:54 at
> akka.dispatch.OnComplete.internal(Future.scala:300)
> 2022-08-17T01:58:54.4621946Z Aug 17 01:58:54 at
> akka.dispatch.OnComplete.internal(Future.scala:297)
> 2022-08-17T01:58:54.4622532Z Aug 17 01:58:54 at
> akka.dispatch.japi$CallbackBridge.apply(Future.scala:224)
> 2022-08-17T01:58:54.4623130Z Aug 17 01:58:54 at
> akka.dispatch.japi$CallbackBridge.apply(Future.scala:221)
> 2022-08-17T01:58:54.4623721Z Aug 17 01:58:54 at
> scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60)
> 2022-08-17T01:58:54.4624832Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.AkkaFutureUtils$DirectExecutionContext.execute(AkkaFutureUtils.java:65)
> 2022-08-17T01:58:54.4625616Z Aug 17 01:58:54 at
> scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68)
> 2022-08-17T01:58:54.4626330Z Aug 17 01:58:54 at
> scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284)
> 2022-08-17T01:58:54.4627084Z Aug 17 01:58:54 at
> scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284)
> 2022-08-17T01:58:54.4627820Z Aug 17 01:58:54 at
> scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
> 2022-08-17T01:58:54.4628461Z Aug 17 01:58:54 at
> akka.pattern.PromiseActorRef.$bang(AskSupport.scala:621)
> 2022-08-17T01:58:54.4629182Z Aug 17 01:58:54 at
> akka.remote.DefaultMessageDispatcher.dispatch(Endpoint.scala:118)
> 2022-08-17T01:58:54.4629852Z Aug 17 01:58:54 at
> akka.remote.EndpointReader$$anonfun$receive$2.applyOrElse(Endpoint.scala:1144)
> 2022-08-17T01:58:54.4630482Z Aug 17 01:58:54 at
> akka.actor.Actor.aroundReceive(Actor.scala:537)
> 2022-08-17T01:58:54.4631039Z Aug 17 01:58:54 at
> akka.actor.Actor.aroundReceive$(Actor.scala:535)
> 2022-08-17T01:58:54.4631621Z Aug 17 01:58:54 at
> akka.remote.EndpointActor.aroundReceive(Endpoint.scala:540)
> 2022-08-17T01:58:54.4632226Z Aug 17 01:58:54 at
> akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
> 2022-08-17T01:58:54.4632786Z Aug 17 01:58:54 at
> akka.actor.ActorCell.invoke(ActorCell.scala:548)
> 2022-08-17T01:58:54.4633467Z Aug 17 01:58:54 at
> akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
> 2022-08-17T01:58:54.4634031Z Aug 17 01:58:54 at
> akka.dispatch.Mailbox.run(Mailbox.scala:231)
> 2022-08-17T01:58:54.4634837Z Aug 17 01:58:54 at
> akka.dispatch.Mailbox.exec(Mailbox.scala:243)
> 2022-08-17T01:58:54.4635289Z Aug 17 01:58:54 ... 4 more
> 2022-08-17T01:58:54.4635804Z Aug 17 01:58:54 Caused by:
> org.apache.flink.runtime.JobException: Recovery is suppressed by
> NoRestartBackoffTimeStrategy
> 2022-08-17T01:58:54.4636634Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
> 2022-08-17T01:58:54.4637592Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
> 2022-08-17T01:58:54.4638471Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
> 2022-08-17T01:58:54.4639331Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
> 2022-08-17T01:58:54.4640374Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
> 2022-08-17T01:58:54.4641202Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:739)
> 2022-08-17T01:58:54.4642110Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
> 2022-08-17T01:58:54.4643090Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1536)
> 2022-08-17T01:58:54.4643943Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1118)
> 2022-08-17T01:58:54.4644765Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1058)
> 2022-08-17T01:58:54.4645485Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.Execution.markFailed(Execution.java:897)
> 2022-08-17T01:58:54.4646221Z Aug 17 01:58:54 at
> org.apache.flink.runtime.executiongraph.ExecutionVertex.markFailed(ExecutionVertex.java:466)
> 2022-08-17T01:58:54.4647057Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultExecutionVertexOperations.markFailed(DefaultExecutionVertexOperations.java:42)
> 2022-08-17T01:58:54.4648066Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskDeploymentFailure(DefaultScheduler.java:658)
> 2022-08-17T01:58:54.4649023Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.lambda$assignAllResourcesAndRegisterProducedPartitions$6(DefaultScheduler.java:530)
> 2022-08-17T01:58:54.4649856Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
> 2022-08-17T01:58:54.4650558Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
> 2022-08-17T01:58:54.4651277Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2022-08-17T01:58:54.4651999Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> 2022-08-17T01:58:54.4652760Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.slotpool.PendingRequest.failRequest(PendingRequest.java:88)
> 2022-08-17T01:58:54.4653612Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.cancelPendingRequests(DeclarativeSlotPoolBridge.java:186)
> 2022-08-17T01:58:54.4654616Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.failPendingRequests(DeclarativeSlotPoolBridge.java:408)
> 2022-08-17T01:58:54.4655540Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.notifyNotEnoughResourcesAvailable(DeclarativeSlotPoolBridge.java:397)
> 2022-08-17T01:58:54.4656515Z Aug 17 01:58:54 at
> org.apache.flink.runtime.jobmaster.JobMaster.notifyNotEnoughResourcesAvailable(JobMaster.java:859)
> 2022-08-17T01:58:54.4657185Z Aug 17 01:58:54 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-08-17T01:58:54.4657812Z Aug 17 01:58:54 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-08-17T01:58:54.4658593Z Aug 17 01:58:54 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-08-17T01:58:54.4659250Z Aug 17 01:58:54 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-08-17T01:58:54.4659915Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$0(AkkaRpcActor.java:296)
> 2022-08-17T01:58:54.4660742Z Aug 17 01:58:54 at
> org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
> 2022-08-17T01:58:54.4661546Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:295)
> 2022-08-17T01:58:54.4662302Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
> 2022-08-17T01:58:54.4663071Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
> 2022-08-17T01:58:54.4663830Z Aug 17 01:58:54 at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
> 2022-08-17T01:58:54.4664771Z Aug 17 01:58:54 at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
> 2022-08-17T01:58:54.4665452Z Aug 17 01:58:54 at
> akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
> 2022-08-17T01:58:54.4666073Z Aug 17 01:58:54 at
> scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
> 2022-08-17T01:58:54.4666690Z Aug 17 01:58:54 at
> scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
> 2022-08-17T01:58:54.4667320Z Aug 17 01:58:54 at
> akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
> 2022-08-17T01:58:54.4667969Z Aug 17 01:58:54 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
> 2022-08-17T01:58:54.4668696Z Aug 17 01:58:54 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> 2022-08-17T01:58:54.4669322Z Aug 17 01:58:54 at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
> 2022-08-17T01:58:54.4669921Z Aug 17 01:58:54 at
> akka.actor.Actor.aroundReceive(Actor.scala:537)
> 2022-08-17T01:58:54.4670574Z Aug 17 01:58:54 at
> akka.actor.Actor.aroundReceive$(Actor.scala:535)
> 2022-08-17T01:58:54.4671167Z Aug 17 01:58:54 at
> akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
> 2022-08-17T01:58:54.4671658Z Aug 17 01:58:54 ... 9 more
> 2022-08-17T01:58:54.4672410Z Aug 17 01:58:54 Caused by:
> java.util.concurrent.CompletionException:
> java.util.concurrent.CompletionException:
> org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
> Could not acquire the minimum required resources.
> 2022-08-17T01:58:54.4673402Z Aug 17 01:58:54 at
> org.apache.flink.runtime.scheduler.DefaultScheduler.lambda$assignResource$8(DefaultScheduler.java:588)
> 2022-08-17T01:58:54.4673967Z Aug 17 01:58:54 ... 39 more
> 2022-08-17T01:58:54.4674726Z Aug 17 01:58:54 Caused by:
> java.util.concurrent.CompletionException:
> org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
> Could not acquire the minimum required resources.
> 2022-08-17T01:58:54.4675584Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
> 2022-08-17T01:58:54.4676316Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
> 2022-08-17T01:58:54.4677019Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:607)
> 2022-08-17T01:58:54.4677716Z Aug 17 01:58:54 at
> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
> 2022-08-17T01:58:54.4678246Z Aug 17 01:58:54 ... 37 more
> 2022-08-17T01:58:54.4678878Z Aug 17 01:58:54 Caused by:
> org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
> Could not acquire the minimum required resources.
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=40085&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461&l=30373
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
