abhijeet2096-confluent commented on PR #28474:
URL: https://github.com/apache/flink/pull/28474#issuecomment-4728533292
Working Logs
```
30205 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Starting the slot manager.
30220 [flink-pekko.actor.default-dispatcher-12] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Registering task executor 8460bb4c-2cd7-4633-8de1-d4a5dc2948eb under
955394dc3060085b63f8e7079f768fe1 at the slot manager.
30288 [flink-pekko.actor.default-dispatcher-12] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Starting the slot manager.
30298 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Registering task executor 1222da61-e536-4cb2-b18a-c27d31c83dbe under
cccd61d5f1e8a6e5eed8079f87898838 at the slot manager.
30301 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Initializing job 'Bounded
TextFiles Test' (d43a5fe8fc6fe1013129d1ff3729de65).
30301 [jobmanager-io-thread-1] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Using
the request slot matching strategy: SimpleRequestSlotMatchingStrategy
30302 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Using restart back off time
strategy FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1,
backoffTimeMS=0) for Bounded TextFiles Test (d43a5fe8fc6fe1013129d1ff3729de65).
30302 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master
for job Bounded TextFiles Test (d43a5fe8fc6fe1013129d1ff3729de65).
30302 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization
on master in 0 ms.
30303 [jobmanager-io-thread-1] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Adding 2 vertices from job graph
Bounded TextFiles Test (d43a5fe8fc6fe1013129d1ff3729de65).
30303 [jobmanager-io-thread-1] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Successfully created execution
graph from job graph Bounded TextFiles Test (d43a5fe8fc6fe1013129d1ff3729de65).
30303 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - State backend is set to heap
memory org.apache.flink.runtime.state.hashmap.HashMapStateBackend@38e3ce32
30303 [jobmanager-io-thread-1] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - The configuration
execution.checkpointing.storage has not be set in the current sessions
config.yaml. Falling back to a default CheckpointStorage type. Users are
strongly encouraged explicitly set this configuration so they understand how
their applications are checkpointing snapshots for fault-tolerance.
30303 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Checkpoint storage is set to
'filesystem': (checkpoints
"file:/var/folders/jn/v1_q4ycn1h96b_k2gr3zmkbw0000gp/T/junit9778931645839140444/junit11908510441715164001")
30304 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Using failover strategy
org.apache.flink.runtime.executiongraph.failover.RestartPipelinedRegionFailoverStrategy@5352a6f2
for Bounded TextFiles Test (d43a5fe8fc6fe1013129d1ff3729de65).
30304 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job
'Bounded TextFiles Test' (d43a5fe8fc6fe1013129d1ff3729de65) under job master id
9de52c550d9898b1ae89af494cc34f79.
30305 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Starting scheduling with
scheduling strategy
[org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy]
30306 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{1136ab0a63b846ba049468f0d67e52e4} and resource profile
ResourceProfile{UNKNOWN}
30306 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{cca0d779837caecdb7efd4f857ea60c4} and resource profile
ResourceProfile{UNKNOWN}
30306 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{6dbfe3d6ab4ec859cfe35f262a1cec65} and resource profile
ResourceProfile{UNKNOWN}
30306 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{25cfb5d79ccb91e342b23b0c885a824a} and resource profile
ResourceProfile{UNKNOWN}
30306 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
30306 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager
pekko.tcp://flink@localhost:57355/user/rpc/resourcemanager_165(98061f1204f05ae3e8e25e10de354019)
30306 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager
address, beginning registration
30306 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager
attempt 1 (timeout=100ms)
30306 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Registration with
ResourceManager at
pekko.tcp://flink@localhost:57355/user/rpc/resourcemanager_165 was successful.
30307 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully
registered at ResourceManager, leader id: 98061f1204f05ae3e8e25e10de354019.
30307 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received resource requirements from job d43a5fe8fc6fe1013129d1ff3729de65:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]
30327 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received resource requirements from job d43a5fe8fc6fe1013129d1ff3729de65:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]
30363 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Matching resource requirements against available resources.
Missing resources:
Job d43a5fe8fc6fe1013129d1ff3729de65
ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}
Current resources:
TaskManager 1222da61-e536-4cb2-b18a-c27d31c83dbe
Available: ResourceProfile{taskHeapMemory=1024.000gb
(1099511627776 bytes), taskOffHeapMemory=1024.000gb (1099511627776 bytes),
managedMemory=80.000mb (83886080 bytes), networkMemory=64.000mb (67108864
bytes)}
Total: ResourceProfile{taskHeapMemory=1024.000gb
(1099511627776 bytes), taskOffHeapMemory=1024.000gb (1099511627776 bytes),
managedMemory=80.000mb (83886080 bytes), networkMemory=64.000mb (67108864
bytes)}
30371 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Register new TaskExecutor 1222da61-e536-4cb2-b18a-c27d31c83dbe.
30372 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot 0933eaf7fe2605e0c2f8e698d14c6c1f @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 5,
AllocatedSlot 1ef98dff86e50816110299305d2bb101 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 4,
AllocatedSlot fbc42fe105a0af97271147b5de4d4f5e @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 6,
AllocatedSlot d22371de3e973639ed47768612675630 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 7]
30372 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{1136ab0a63b846ba049468f0d67e52e4},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=1.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot 0933eaf7fe2605e0c2f8e698d14c6c1f @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 5.
30372 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot 0933eaf7fe2605e0c2f8e698d14c6c1f for slot request id
SlotRequestId{1136ab0a63b846ba049468f0d67e52e4}
30372 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{cca0d779837caecdb7efd4f857ea60c4},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=1.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot 1ef98dff86e50816110299305d2bb101 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 4.
30372 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot 1ef98dff86e50816110299305d2bb101 for slot request id
SlotRequestId{cca0d779837caecdb7efd4f857ea60c4}
30372 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{6dbfe3d6ab4ec859cfe35f262a1cec65},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=1.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot fbc42fe105a0af97271147b5de4d4f5e @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 6.
30372 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot fbc42fe105a0af97271147b5de4d4f5e for slot request id
SlotRequestId{6dbfe3d6ab4ec859cfe35f262a1cec65}
30372 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{25cfb5d79ccb91e342b23b0c885a824a},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=2.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot d22371de3e973639ed47768612675630 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 7.
30372 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot d22371de3e973639ed47768612675630 for slot request id
SlotRequestId{25cfb5d79ccb91e342b23b0c885a824a}
30381 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
30381 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
30382 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
30382 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
30383 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
30390 [flink-pekko.actor.default-dispatcher-12] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
'Bounded TextFiles Test' (d43a5fe8fc6fe1013129d1ff3729de65).
30391 [flink-pekko.actor.default-dispatcher-12] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{1136ab0a63b846ba049468f0d67e52e4}
30391 [flink-pekko.actor.default-dispatcher-12] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot 0933eaf7fe2605e0c2f8e698d14c6c1f @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 5]
30391 [flink-pekko.actor.default-dispatcher-12] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{cca0d779837caecdb7efd4f857ea60c4}
30391 [flink-pekko.actor.default-dispatcher-12] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot 1ef98dff86e50816110299305d2bb101 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 4]
30391 [flink-pekko.actor.default-dispatcher-12] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{6dbfe3d6ab4ec859cfe35f262a1cec65}
30391 [flink-pekko.actor.default-dispatcher-12] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot fbc42fe105a0af97271147b5de4d4f5e @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 6]
30391 [flink-pekko.actor.default-dispatcher-12] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{25cfb5d79ccb91e342b23b0c885a824a}
30391 [flink-pekko.actor.default-dispatcher-12] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot d22371de3e973639ed47768612675630 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 7]
30392 [flink-pekko.actor.default-dispatcher-12] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
3c638f589b2f3f12a5b42608532d8a67.
java.lang.Exception: Job leader lost leadership.
at
org.apache.flink.runtime.resourcemanager.ResourceManager.jobLeaderLostLeadership(ResourceManager.java:1233)
at
org.apache.flink.runtime.resourcemanager.ResourceManager$JobLeaderIdActionsImpl.lambda$jobLeaderLostLeadership$0(ResourceManager.java:1440)
at
org.apache.flink.util.MdcUtils.lambda$wrapRunnable$1(MdcUtils.java:70)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRunAsync$4(PekkoRpcActor.java:460)
at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRunAsync(PekkoRpcActor.java:460)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:225)
at
org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:88)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:174)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:37)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:33)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:273)
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:234)
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:246)
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1312)
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843)
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808)
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188)
30392 [flink-pekko.actor.default-dispatcher-12] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager
pekko.tcp://flink@localhost:57355/user/rpc/resourcemanager_165(98061f1204f05ae3e8e25e10de354019)
30392 [flink-pekko.actor.default-dispatcher-12] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Disconnect TaskExecutor
1222da61-e536-4cb2-b18a-c27d31c83dbe because: Stopping JobMaster for job
'Bounded TextFiles Test' (d43a5fe8fc6fe1013129d1ff3729de65).
30393 [jobmanager-future-thread-10] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Retrying registration towards
pekko.tcp://flink@localhost:57355/user/rpc/resourcemanager_165 was cancelled.
30395 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager
address, beginning registration
30398 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Initializing job 'Bounded
TextFiles Test' (d43a5fe8fc6fe1013129d1ff3729de65).
30398 [jobmanager-io-thread-2] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Using
the request slot matching strategy: SimpleRequestSlotMatchingStrategy
30400 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Using restart back off time
strategy FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1,
backoffTimeMS=0) for Bounded TextFiles Test (d43a5fe8fc6fe1013129d1ff3729de65).
30401 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master
for job Bounded TextFiles Test (d43a5fe8fc6fe1013129d1ff3729de65).
30401 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization
on master in 0 ms.
30401 [jobmanager-io-thread-2] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Adding 2 vertices from job graph
Bounded TextFiles Test (d43a5fe8fc6fe1013129d1ff3729de65).
30401 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot 0933eaf7fe2605e0c2f8e698d14c6c1f.
30401 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot fbc42fe105a0af97271147b5de4d4f5e.
30401 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot d22371de3e973639ed47768612675630.
30401 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot 1ef98dff86e50816110299305d2bb101.
30402 [jobmanager-io-thread-2] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Successfully created execution
graph from job graph Bounded TextFiles Test (d43a5fe8fc6fe1013129d1ff3729de65).
30402 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - State backend is set to heap
memory org.apache.flink.runtime.state.hashmap.HashMapStateBackend@1a7ec539
30402 [jobmanager-io-thread-2] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - The configuration
execution.checkpointing.storage has not be set in the current sessions
config.yaml. Falling back to a default CheckpointStorage type. Users are
strongly encouraged explicitly set this configuration so they understand how
their applications are checkpointing snapshots for fault-tolerance.
30402 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Checkpoint storage is set to
'filesystem': (checkpoints
"file:/var/folders/jn/v1_q4ycn1h96b_k2gr3zmkbw0000gp/T/junit9778931645839140444/junit11908510441715164001")
30402 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Using failover strategy
org.apache.flink.runtime.executiongraph.failover.RestartPipelinedRegionFailoverStrategy@13b792db
for Bounded TextFiles Test (d43a5fe8fc6fe1013129d1ff3729de65).
30402 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot fbc42fe105a0af97271147b5de4d4f5e.
30402 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Trying to free a slot fbc42fe105a0af97271147b5de4d4f5e which has not been
allocated. Ignoring this message.
30402 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot d22371de3e973639ed47768612675630.
30402 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Trying to free a slot d22371de3e973639ed47768612675630 which has not been
allocated. Ignoring this message.
30403 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job
'Bounded TextFiles Test' (d43a5fe8fc6fe1013129d1ff3729de65) under job master id
865e7ad3cb8d0b0f5acb515ce05b4d21.
30404 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Starting scheduling with
scheduling strategy
[org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy]
30404 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{c3ae6fa96c4cc2bf2855662ab50fed54} and resource profile
ResourceProfile{UNKNOWN}
30404 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{59588e565c34c01b984d414b31070117} and resource profile
ResourceProfile{UNKNOWN}
30404 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{85e84353faeebc9263d30b20dd265eaa} and resource profile
ResourceProfile{UNKNOWN}
30404 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{34db488e9ed2932fdfe5ceabb402353d} and resource profile
ResourceProfile{UNKNOWN}
30405 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager
pekko.tcp://flink@localhost:57355/user/rpc/resourcemanager_165(98061f1204f05ae3e8e25e10de354019)
30405 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
30405 [flink-pekko.actor.default-dispatcher-12] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager
address, beginning registration
30405 [flink-pekko.actor.default-dispatcher-12] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager
attempt 1 (timeout=100ms)
30406 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Registration with
ResourceManager at
pekko.tcp://flink@localhost:57355/user/rpc/resourcemanager_165 was successful.
30406 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully
registered at ResourceManager, leader id: 98061f1204f05ae3e8e25e10de354019.
30406 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received resource requirements from job d43a5fe8fc6fe1013129d1ff3729de65:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]
30429 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received resource requirements from job d43a5fe8fc6fe1013129d1ff3729de65:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]
30462 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Matching resource requirements against available resources.
Missing resources:
Job d43a5fe8fc6fe1013129d1ff3729de65
ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}
Current resources:
TaskManager 1222da61-e536-4cb2-b18a-c27d31c83dbe
Available: ResourceProfile{taskHeapMemory=1024.000gb
(1099511627776 bytes), taskOffHeapMemory=1024.000gb (1099511627776 bytes),
managedMemory=80.000mb (83886080 bytes), networkMemory=64.000mb (67108864
bytes)}
Total: ResourceProfile{taskHeapMemory=1024.000gb
(1099511627776 bytes), taskOffHeapMemory=1024.000gb (1099511627776 bytes),
managedMemory=80.000mb (83886080 bytes), networkMemory=64.000mb (67108864
bytes)}
30479 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Register new TaskExecutor 1222da61-e536-4cb2-b18a-c27d31c83dbe.
30481 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot 6238df30057c62772d44c82a0a4df460 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 10,
AllocatedSlot 91ac9e4ed25996e35711d5274b1128ea @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 11,
AllocatedSlot ee45eb2fc367312219992b27557d4d23 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 8,
AllocatedSlot 9626ea3042abcdad2bd64db743936585 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 9]
30481 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{c3ae6fa96c4cc2bf2855662ab50fed54},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=2.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot 6238df30057c62772d44c82a0a4df460 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 10.
30481 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot 6238df30057c62772d44c82a0a4df460 for slot request id
SlotRequestId{c3ae6fa96c4cc2bf2855662ab50fed54}
30481 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{59588e565c34c01b984d414b31070117},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=1.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot 91ac9e4ed25996e35711d5274b1128ea @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 11.
30481 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot 91ac9e4ed25996e35711d5274b1128ea for slot request id
SlotRequestId{59588e565c34c01b984d414b31070117}
30481 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{85e84353faeebc9263d30b20dd265eaa},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=1.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot ee45eb2fc367312219992b27557d4d23 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 8.
30481 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot ee45eb2fc367312219992b27557d4d23 for slot request id
SlotRequestId{85e84353faeebc9263d30b20dd265eaa}
30481 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{34db488e9ed2932fdfe5ceabb402353d},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=1.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot 9626ea3042abcdad2bd64db743936585 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 9.
30481 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot 9626ea3042abcdad2bd64db743936585 for slot request id
SlotRequestId{34db488e9ed2932fdfe5ceabb402353d}
30489 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
30493 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
30494 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
30494 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
30494 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
30520 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{59588e565c34c01b984d414b31070117}
30520 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot 91ac9e4ed25996e35711d5274b1128ea @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 11]
30520 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{34db488e9ed2932fdfe5ceabb402353d}
30520 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot 9626ea3042abcdad2bd64db743936585 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 9]
30521 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{85e84353faeebc9263d30b20dd265eaa}
30521 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot ee45eb2fc367312219992b27557d4d23 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 8]
30528 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{c3ae6fa96c4cc2bf2855662ab50fed54}
30529 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot 6238df30057c62772d44c82a0a4df460 @
1222da61-e536-4cb2-b18a-c27d31c83dbe @ localhost (dataPort=-1) - 10]
30531 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
'Bounded TextFiles Test' (d43a5fe8fc6fe1013129d1ff3729de65).
30533 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Disconnect TaskExecutor
1222da61-e536-4cb2-b18a-c27d31c83dbe because: Stopping JobMaster for job
'Bounded TextFiles Test' (d43a5fe8fc6fe1013129d1ff3729de65).
30533 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
3c638f589b2f3f12a5b42608532d8a67.
org.apache.flink.util.FlinkException: Stopping JobMaster for job 'Bounded
TextFiles Test' (d43a5fe8fc6fe1013129d1ff3729de65).
at
org.apache.flink.runtime.jobmaster.JobMaster.onStop(JobMaster.java:506)
at
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:255)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor$StartedState.lambda$terminate$0(PekkoRpcActor.java:583)
at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor$StartedState.terminate(PekkoRpcActor.java:582)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleControlMessage(PekkoRpcActor.java:203)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:37)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:33)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:273)
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:234)
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:246)
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoΩinPool.java:1312)
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843)
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808)
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188)
30534 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot 6238df30057c62772d44c82a0a4df460.
30535 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot 91ac9e4ed25996e35711d5274b1128ea.
30535 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot 9626ea3042abcdad2bd64db743936585.
30535 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot ee45eb2fc367312219992b27557d4d23.
30629 [flink-pekko.actor.default-dispatcher-13] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Unregistering task executor cccd61d5f1e8a6e5eed8079f87898838 from the slot
manager.
30633 [flink-pekko.actor.default-dispatcher-12] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Closing the slot manager.
30633 [flink-pekko.actor.default-dispatcher-12] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Suspending the slot manager.
```
Flaky Logs
```
30882 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Starting the slot manager.
30934 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Registering task executor 38efe265-615a-4016-b7c3-699274a6bdaf under
64680791e4920880e5585e4d82cdee4a at the slot manager.
30995 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Starting the slot manager.
31020 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Initializing job 'Bounded
TextFiles Test' (870b4de786904f66c59d53a1cc0838f9).
31020 [jobmanager-io-thread-1] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Using
the request slot matching strategy: SimpleRequestSlotMatchingStrategy
31021 [flink-pekko.actor.default-dispatcher-15] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Registering task executor 8901ace8-43cc-41f5-b975-4a01f37f19af under
1e764bf0cbc474e4a4c2e61b109884f1 at the slot manager.
31023 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Using restart back off time
strategy FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1,
backoffTimeMS=0) for Bounded TextFiles Test (870b4de786904f66c59d53a1cc0838f9).
31023 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master
for job Bounded TextFiles Test (870b4de786904f66c59d53a1cc0838f9).
31023 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization
on master in 0 ms.
31023 [jobmanager-io-thread-1] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Adding 2 vertices from job graph
Bounded TextFiles Test (870b4de786904f66c59d53a1cc0838f9).
31024 [jobmanager-io-thread-1] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Successfully created execution
graph from job graph Bounded TextFiles Test (870b4de786904f66c59d53a1cc0838f9).
31024 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - State backend is set to heap
memory org.apache.flink.runtime.state.hashmap.HashMapStateBackend@4e0a0082
31024 [jobmanager-io-thread-1] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - The configuration
execution.checkpointing.storage has not be set in the current sessions
config.yaml. Falling back to a default CheckpointStorage type. Users are
strongly encouraged explicitly set this configuration so they understand how
their applications are checkpointing snapshots for fault-tolerance.
31024 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Checkpoint storage is set to
'filesystem': (checkpoints
"file:/var/folders/jn/v1_q4ycn1h96b_k2gr3zmkbw0000gp/T/junit9603636946577191623/junit7119544660679143141")
31024 [jobmanager-io-thread-1] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Using failover strategy
org.apache.flink.runtime.executiongraph.failover.RestartPipelinedRegionFailoverStrategy@b38c658
for Bounded TextFiles Test (870b4de786904f66c59d53a1cc0838f9).
31025 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job
'Bounded TextFiles Test' (870b4de786904f66c59d53a1cc0838f9) under job master id
851bc0434a46da0f3120b5ebde424508.
31027 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Starting scheduling with
scheduling strategy
[org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy]
31028 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{10de6be5396d8cb1663d5c7ed3e24f50} and resource profile
ResourceProfile{UNKNOWN}
31028 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{a46218fa5c78ac34df5772a0c91c94d8} and resource profile
ResourceProfile{UNKNOWN}
31028 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{f02dbda864b611a013e11554fce52349} and resource profile
ResourceProfile{UNKNOWN}
31028 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{5729869465f13bd0a40737353f8969a9} and resource profile
ResourceProfile{UNKNOWN}
31029 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
31029 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager
pekko.tcp://flink@localhost:57374/user/rpc/resourcemanager_173(8dcbc16d8f0e12fc2f81d91138084573)
31029 [flink-pekko.actor.default-dispatcher-15] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager
address, beginning registration
31029 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager
attempt 1 (timeout=100ms)
31031 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Registration with
ResourceManager at
pekko.tcp://flink@localhost:57374/user/rpc/resourcemanager_173 was successful.
31032 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully
registered at ResourceManager, leader id: 8dcbc16d8f0e12fc2f81d91138084573.
31032 [flink-pekko.actor.default-dispatcher-15] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received resource requirements from job 870b4de786904f66c59d53a1cc0838f9:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]
31053 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received resource requirements from job 870b4de786904f66c59d53a1cc0838f9:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]
31088 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Matching resource requirements against available resources.
Missing resources:
Job 870b4de786904f66c59d53a1cc0838f9
ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}
Current resources:
TaskManager 8901ace8-43cc-41f5-b975-4a01f37f19af
Available: ResourceProfile{taskHeapMemory=1024.000gb
(1099511627776 bytes), taskOffHeapMemory=1024.000gb (1099511627776 bytes),
managedMemory=80.000mb (83886080 bytes), networkMemory=64.000mb (67108864
bytes)}
Total: ResourceProfile{taskHeapMemory=1024.000gb
(1099511627776 bytes), taskOffHeapMemory=1024.000gb (1099511627776 bytes),
managedMemory=80.000mb (83886080 bytes), networkMemory=64.000mb (67108864
bytes)}
31096 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Register new TaskExecutor 8901ace8-43cc-41f5-b975-4a01f37f19af.
31098 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot 5e4e864bb44d88b22d56b980bc7eb89a @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 5,
AllocatedSlot b85c27ab07d67335b2feff62f384c81d @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 7,
AllocatedSlot 23b3cbb13d8fd8cc662ab676f496604f @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 6,
AllocatedSlot ab34d8bf03aa7a02bd37d30ae516e0ee @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 4]
31099 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{10de6be5396d8cb1663d5c7ed3e24f50},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=1.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot 5e4e864bb44d88b22d56b980bc7eb89a @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 5.
31099 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot 5e4e864bb44d88b22d56b980bc7eb89a for slot request id
SlotRequestId{10de6be5396d8cb1663d5c7ed3e24f50}
31099 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{a46218fa5c78ac34df5772a0c91c94d8},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=1.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot b85c27ab07d67335b2feff62f384c81d @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 7.
31099 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot b85c27ab07d67335b2feff62f384c81d for slot request id
SlotRequestId{a46218fa5c78ac34df5772a0c91c94d8}
31099 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{f02dbda864b611a013e11554fce52349},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=2.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot 23b3cbb13d8fd8cc662ab676f496604f @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 6.
31099 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot 23b3cbb13d8fd8cc662ab676f496604f for slot request id
SlotRequestId{f02dbda864b611a013e11554fce52349}
31099 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Matched
pending request
PendingRequest{slotRequestId=SlotRequestId{5729869465f13bd0a40737353f8969a9},
resourceProfile=ResourceProfile{UNKNOWN},
taskExecutionLoad=DefaultTaskExecutionLoad{load=1.0}, preferredAllocations=[],
isBatchRequest=false, unfulfillableSince=9223372036854775807} with slot
AllocatedSlot ab34d8bf03aa7a02bd37d30ae516e0ee @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 4.
31099 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Reserve
slot ab34d8bf03aa7a02bd37d30ae516e0ee for slot request id
SlotRequestId{5729869465f13bd0a40737353f8969a9}
31116 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
31119 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
31119 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Ignoring
reportInitializationMetrics if checkpointing is not present
31122 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
'Bounded TextFiles Test' (870b4de786904f66c59d53a1cc0838f9).
31123 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{a46218fa5c78ac34df5772a0c91c94d8}
31123 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot b85c27ab07d67335b2feff62f384c81d @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 7]
31124 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{10de6be5396d8cb1663d5c7ed3e24f50}
31124 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot 5e4e864bb44d88b22d56b980bc7eb89a @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 5]
31124 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{5729869465f13bd0a40737353f8969a9}
31124 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot ab34d8bf03aa7a02bd37d30ae516e0ee @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 4]
31124 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{f02dbda864b611a013e11554fce52349}
31124 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge -
Received new available slots: [AllocatedSlot 23b3cbb13d8fd8cc662ab676f496604f @
8901ace8-43cc-41f5-b975-4a01f37f19af @ localhost (dataPort=-1) - 6]
31125 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
15f86f8df5dc4605d4aa8a2b3150c6aa.
java.lang.Exception: Job leader lost leadership.
at
org.apache.flink.runtime.resourcemanager.ResourceManager.jobLeaderLostLeadership(ResourceManager.java:1233)
at
org.apache.flink.runtime.resourcemanager.ResourceManager$JobLeaderIdActionsImpl.lambda$jobLeaderLostLeadership$0(ResourceManager.java:1440)
at
org.apache.flink.util.MdcUtils.lambda$wrapRunnable$1(MdcUtils.java:70)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRunAsync$4(PekkoRpcActor.java:460)
at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRunAsync(PekkoRpcActor.java:460)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:225)
at
org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:88)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:174)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:37)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:33)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:273)
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:234)
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:246)
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1312)
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843)
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808)
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188)
31125 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager
pekko.tcp://flink@localhost:57374/user/rpc/resourcemanager_173(8dcbc16d8f0e12fc2f81d91138084573)
31126 [flink-pekko.actor.default-dispatcher-15] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager
address, beginning registration
31126 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager
attempt 1 (timeout=100ms)
31126 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Disconnect TaskExecutor
8901ace8-43cc-41f5-b975-4a01f37f19af because: Stopping JobMaster for job
'Bounded TextFiles Test' (870b4de786904f66c59d53a1cc0838f9).
31126 [jobmanager-future-thread-10] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Retrying registration towards
pekko.tcp://flink@localhost:57374/user/rpc/resourcemanager_173 was cancelled.
31130 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Initializing job 'Bounded
TextFiles Test' (870b4de786904f66c59d53a1cc0838f9).
31130 [jobmanager-io-thread-2] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Using
the request slot matching strategy: SimpleRequestSlotMatchingStrategy
31135 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot b85c27ab07d67335b2feff62f384c81d.
31137 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot ab34d8bf03aa7a02bd37d30ae516e0ee.
31138 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Freeing slot ab34d8bf03aa7a02bd37d30ae516e0ee.
31138 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Trying to free a slot ab34d8bf03aa7a02bd37d30ae516e0ee which has not been
allocated. Ignoring this message.
31140 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Unregistering task executor 1e764bf0cbc474e4a4c2e61b109884f1 from the slot
manager.
31146 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Using restart back off time
strategy FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1,
backoffTimeMS=0) for Bounded TextFiles Test (870b4de786904f66c59d53a1cc0838f9).
31147 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master
for job Bounded TextFiles Test (870b4de786904f66c59d53a1cc0838f9).
31147 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization
on master in 0 ms.
31147 [jobmanager-io-thread-2] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Adding 2 vertices from job graph
Bounded TextFiles Test (870b4de786904f66c59d53a1cc0838f9).
31150 [jobmanager-io-thread-2] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Successfully created execution
graph from job graph Bounded TextFiles Test (870b4de786904f66c59d53a1cc0838f9).
31151 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - State backend is set to heap
memory org.apache.flink.runtime.state.hashmap.HashMapStateBackend@19a15759
31152 [jobmanager-io-thread-2] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - The configuration
execution.checkpointing.storage has not be set in the current sessions
config.yaml. Falling back to a default CheckpointStorage type. Users are
strongly encouraged explicitly set this configuration so they understand how
their applications are checkpointing snapshots for fault-tolerance.
31153 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Checkpoint storage is set to
'filesystem': (checkpoints
"file:/var/folders/jn/v1_q4ycn1h96b_k2gr3zmkbw0000gp/T/junit9603636946577191623/junit7119544660679143141")
31154 [jobmanager-io-thread-2] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Using failover strategy
org.apache.flink.runtime.executiongraph.failover.RestartPipelinedRegionFailoverStrategy@31204dad
for Bounded TextFiles Test (870b4de786904f66c59d53a1cc0838f9).
31156 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job
'Bounded TextFiles Test' (870b4de786904f66c59d53a1cc0838f9) under job master id
a4673d06e4de1dec7f22ebc6b4e7411c.
31157 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Starting scheduling with
scheduling strategy
[org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy]
31158 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{899672a72f4fc50f092336267cf724f3} and resource profile
ResourceProfile{UNKNOWN}
31158 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{95f315d3fa75784c1d9d53f987e82497} and resource profile
ResourceProfile{UNKNOWN}
31158 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{9518f49018d06adf1728e11260f4d63b} and resource profile
ResourceProfile{UNKNOWN}
31158 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{311aab4c37d1aa68b8e62241083356f7} and resource profile
ResourceProfile{UNKNOWN}
31159 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
31159 [flink-pekko.actor.default-dispatcher-14] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager
pekko.tcp://flink@localhost:57374/user/rpc/resourcemanager_173(8dcbc16d8f0e12fc2f81d91138084573)
31160 [flink-pekko.actor.default-dispatcher-19] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager
address, beginning registration
31160 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager
attempt 1 (timeout=100ms)
31161 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Registration with
ResourceManager at
pekko.tcp://flink@localhost:57374/user/rpc/resourcemanager_173 was successful.
31161 [flink-pekko.actor.default-dispatcher-19] INFO
org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully
registered at ResourceManager, leader id: 8dcbc16d8f0e12fc2f81d91138084573.
31161 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received resource requirements from job 870b4de786904f66c59d53a1cc0838f9:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]
31183 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received resource requirements from job 870b4de786904f66c59d53a1cc0838f9:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]
31196 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Matching resource requirements against available resources.
Missing resources:
Job 870b4de786904f66c59d53a1cc0838f9
ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}
Current resources:
(none)
40955 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
41000 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
41164 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
50907 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
51005 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
51171 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
60912 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
61010 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
61177 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
70965 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
71013 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
71179 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
80966 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
81016 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
81189 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
90943 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
91033 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
91195 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
100942 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
101033 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
101199 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
110951 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
111036 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
111202 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
120953 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
121039 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
121206 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
130955 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
131044 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
131208 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
140956 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
141044 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
141211 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
150957 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
151047 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
151230 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
160960 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
161053 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
161234 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
170967 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
171054 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
171239 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
180971 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
181055 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
181243 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
190970 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
191057 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
191246 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
200973 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
201058 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
201254 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
210989 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
211069 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
211259 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
220972 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
221072 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
221264 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
230987 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
231077 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
231272 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
240985 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
241079 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
241277 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
250987 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
251084 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
251283 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
260985 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
261086 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
261284 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
270989 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
271088 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
271288 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
280997 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
281089 [flink-pekko.actor.default-dispatcher-15] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
281294 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
291001 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
291091 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
291298 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
301000 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
301091 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
301304 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
311003 [flink-pekko.actor.default-dispatcher-5] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
311092 [flink-pekko.actor.default-dispatcher-14] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
311310 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
321001 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
321093 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
321315 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
331006 [flink-pekko.actor.default-dispatcher-13] DEBUG
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received slot report from instance 64680791e4920880e5585e4d82cdee4a: SlotReport{
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_0,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_1,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_2,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}
SlotStatus{slotID=38efe265-615a-4016-b7c3-699274a6bdaf_3,
allocationID=null, jobID=null, assignedTasks=0,
resourceProfile=ResourceProfile{taskHeapMemory=256.000gb (274877906944 bytes),
taskOffHeapMemory=256.000gb (274877906944 bytes), managedMemory=20.000mb
(20971520 bytes), networkMemory=16.000mb (16777216 bytes)}}}.
331048 [flink-pekko.actor.default-dispatcher-6] WARN
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Could
not acquire the minimum required resources, failing slot requests. Acquired:
[]. Current slot pool status: Registered TMs: 0, registered slots: 0 free
slots: 0
331055 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{899672a72f4fc50f092336267cf724f3}
331055 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Could
not find slot which has fulfilled slot request
SlotRequestId{899672a72f4fc50f092336267cf724f3}. Ignoring the release operation.
331195 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - 5 tasks will be restarted to
recover the failed task
22e4e69f4743b7c7e24fd1aec24e0101_cbc357ccb763df2852fee8c4fc7d55f2_1_0.
331200 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{95f315d3fa75784c1d9d53f987e82497}
331200 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Could
not find slot which has fulfilled slot request
SlotRequestId{95f315d3fa75784c1d9d53f987e82497}. Ignoring the release operation.
331201 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{311aab4c37d1aa68b8e62241083356f7}
331201 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Could
not find slot which has fulfilled slot request
SlotRequestId{311aab4c37d1aa68b8e62241083356f7}. Ignoring the release operation.
331202 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{9518f49018d06adf1728e11260f4d63b}
331202 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Could
not find slot which has fulfilled slot request
SlotRequestId{9518f49018d06adf1728e11260f4d63b}. Ignoring the release operation.
331220 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Archive local failure causing
attempt 22e4e69f4743b7c7e24fd1aec24e0101_cbc357ccb763df2852fee8c4fc7d55f2_1_0
to fail: 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.DefaultExecutionDeployer.lambda$assignResource$4(DefaultExecutionDeployer.java:226)
at
java.base/java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:934)
at
java.base/java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:911)
at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2194)
at
org.apache.flink.runtime.jobmaster.slotpool.PendingRequest.failRequest(PendingRequest.java:101)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.cancelPendingRequests(DeclarativeSlotPoolBridge.java:234)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.failPendingRequests(DeclarativeSlotPoolBridge.java:520)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.notifyNotEnoughResourcesAvailable(DeclarativeSlotPoolBridge.java:508)
at
org.apache.flink.runtime.jobmaster.JobMaster.notifyNotEnoughResourcesAvailable(JobMaster.java:995)
at
java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$0(PekkoRpcActor.java:310)
at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:309)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:229)
at
org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:88)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:174)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:37)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:33)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:273)
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:234)
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:246)
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1312)
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843)
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808)
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188)
Caused by: java.util.concurrent.CompletionException:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
at
java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:332)
at
java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:347)
at
java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:636)
... 36 more
Caused by:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
331231 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from
15f86f8df5dc4605d4aa8a2b3150c6aa.
331260 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{90591014558ccdabefcaef222baacf90} and resource profile
ResourceProfile{UNKNOWN}
331261 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{c2e7d93c2eee71f4fd0c0975f6332561} and resource profile
ResourceProfile{UNKNOWN}
331261 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{95ac6d65105ec1310c1fc75db6e79818} and resource profile
ResourceProfile{UNKNOWN}
331261 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Request
new allocated slot with slot request id
SlotRequestId{8513c0abc82693b528a4eabe1b43079e} and resource profile
ResourceProfile{UNKNOWN}
331289 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Received resource requirements from job 870b4de786904f66c59d53a1cc0838f9:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]
331321 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
331360 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Matching resource requirements against available resources.
Missing resources:
Job 870b4de786904f66c59d53a1cc0838f9
ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}
Current resources:
(none)
331373 [flink-pekko.actor.default-dispatcher-6] WARN
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Could not fulfill resource requirements of job 870b4de786904f66c59d53a1cc0838f9.
331375 [flink-pekko.actor.default-dispatcher-19] WARN
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Could
not acquire the minimum required resources, failing slot requests. Acquired:
[]. Current slot pool status: Registered TMs: 0, registered slots: 0 free
slots: 0
331375 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{90591014558ccdabefcaef222baacf90}
331375 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Could
not find slot which has fulfilled slot request
SlotRequestId{90591014558ccdabefcaef222baacf90}. Ignoring the release operation.
331379 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{c2e7d93c2eee71f4fd0c0975f6332561}
331379 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Could
not find slot which has fulfilled slot request
SlotRequestId{c2e7d93c2eee71f4fd0c0975f6332561}. Ignoring the release operation.
331379 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{95ac6d65105ec1310c1fc75db6e79818}
331379 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Could
not find slot which has fulfilled slot request
SlotRequestId{95ac6d65105ec1310c1fc75db6e79818}. Ignoring the release operation.
331380 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Release
slot with slot request id SlotRequestId{8513c0abc82693b528a4eabe1b43079e}
331380 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge - Could
not find slot which has fulfilled slot request
SlotRequestId{8513c0abc82693b528a4eabe1b43079e}. Ignoring the release operation.
331386 [flink-pekko.actor.default-dispatcher-19] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Archive global failure.
org.apache.flink.runtime.JobException: Recovery is suppressed by
FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1,
backoffTimeMS=0)
at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:213)
at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.handleFailureAndReport(ExecutionFailureHandler.java:163)
at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:118)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:300)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:291)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:284)
at
org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:836)
at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:813)
at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1741)
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1361)
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1301)
at
org.apache.flink.runtime.executiongraph.Execution.markFailed(Execution.java:1140)
at
org.apache.flink.runtime.scheduler.DefaultExecutionOperations.markFailed(DefaultExecutionOperations.java:43)
at
org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.handleTaskDeploymentFailure(DefaultExecutionDeployer.java:329)
at
org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.lambda$assignAllResourcesAndRegisterProducedPartitions$2(DefaultExecutionDeployer.java:169)
at
java.base/java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:934)
at
java.base/java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:911)
at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2194)
at
org.apache.flink.runtime.jobmaster.slotpool.PendingRequest.failRequest(PendingRequest.java:101)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.cancelPendingRequests(DeclarativeSlotPoolBridge.java:234)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.failPendingRequests(DeclarativeSlotPoolBridge.java:520)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.notifyNotEnoughResourcesAvailable(DeclarativeSlotPoolBridge.java:508)
at
org.apache.flink.runtime.jobmaster.JobMaster.notifyNotEnoughResourcesAvailable(JobMaster.java:995)
at
java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$0(PekkoRpcActor.java:310)
at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:309)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:229)
at
org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:88)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:174)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:37)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:33)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:273)
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:234)
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:246)
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1312)
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843)
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808)
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188)
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.DefaultExecutionDeployer.lambda$assignResource$4(DefaultExecutionDeployer.java:226)
... 38 more
Caused by: java.util.concurrent.CompletionException:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
at
java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:332)
at
java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:347)
at
java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:636)
... 36 more
Caused by:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
331411 [flink-pekko.actor.default-dispatcher-6] INFO
org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job
'Bounded TextFiles Test' (870b4de786904f66c59d53a1cc0838f9).
331431 [flink-pekko.actor.default-dispatcher-6] DEBUG
org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection
15f86f8df5dc4605d4aa8a2b3150c6aa.
org.apache.flink.util.FlinkException: Stopping JobMaster for job 'Bounded
TextFiles Test' (870b4de786904f66c59d53a1cc0838f9).
at
org.apache.flink.runtime.jobmaster.JobMaster.onStop(JobMaster.java:506)
at
org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:255)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor$StartedState.lambda$terminate$0(PekkoRpcActor.java:583)
at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor$StartedState.terminate(PekkoRpcActor.java:582)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleControlMessage(PekkoRpcActor.java:203)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:37)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:33)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:273)
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:234)
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:246)
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1312)
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843)
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808)
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188)
331531 [flink-pekko.actor.default-dispatcher-15] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Closing the slot manager.
331532 [flink-pekko.actor.default-dispatcher-15] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager -
Suspending the slot manager.
java.lang.RuntimeException: Failed to fetch next result
at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:127)
at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:98)
at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.testBoundedTextFileSource(FileSourceTextLinesITCase.java:176)
at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.testBoundedTextFileSource(FileSourceTextLinesITCase.java:129)
at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.lambda$testBoundedTextFileSourceWithJobManagerFailover$1(FileSourceTextLinesITCase.java:116)
at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.runTestWithNewMiniCluster(FileSourceTextLinesITCase.java:316)
at
org.apache.flink.connector.file.src.FileSourceTextLinesITCase.testBoundedTextFileSourceWithJobManagerFailover(FileSourceTextLinesITCase.java:115)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:387)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1312)
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1843)
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1808)
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:188)
Caused by: java.io.IOException: Failed to fetch job execution result
at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:189)
at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:122)
at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:124)
... 12 more
Caused by: java.util.concurrent.ExecutionException:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
at
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:396)
at
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:2096)
at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:187)
... 14 more
Caused by: org.apache.flink.runtime.client.JobExecutionException: Job
execution failed.
at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:180)
at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:140)
at
java.base/java.util.concurrent.CompletableFuture.uniApplyNow(CompletableFuture.java:684)
at
java.base/java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:662)
at
java.base/java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:2200)
at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:137)
at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:186)
... 14 more
Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by
FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=1,
backoffTimeMS=0)
at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:213)
at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.handleFailureAndReport(ExecutionFailureHandler.java:163)
at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:118)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:300)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:291)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:284)
at
org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:836)
at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:813)
at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1741)
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1361)
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1301)
at
org.apache.flink.runtime.executiongraph.Execution.markFailed(Execution.java:1140)
at
org.apache.flink.runtime.scheduler.DefaultExecutionOperations.markFailed(DefaultExecutionOperations.java:43)
at
org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.handleTaskDeploymentFailure(DefaultExecutionDeployer.java:329)
at
org.apache.flink.runtime.scheduler.DefaultExecutionDeployer.lambda$assignAllResourcesAndRegisterProducedPartitions$2(DefaultExecutionDeployer.java:169)
at
java.base/java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:934)
at
java.base/java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:911)
at
java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
at
java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2194)
at
org.apache.flink.runtime.jobmaster.slotpool.PendingRequest.failRequest(PendingRequest.java:101)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.cancelPendingRequests(DeclarativeSlotPoolBridge.java:234)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.failPendingRequests(DeclarativeSlotPoolBridge.java:520)
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolBridge.notifyNotEnoughResourcesAvailable(DeclarativeSlotPoolBridge.java:508)
at
org.apache.flink.runtime.jobmaster.JobMaster.notifyNotEnoughResourcesAvailable(JobMaster.java:995)
at java.base/java.lang.reflect.Method.invoke(Method.java:580)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRpcInvocation$0(PekkoRpcActor.java:310)
at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcInvocation(PekkoRpcActor.java:309)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:229)
at
org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:88)
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:174)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:37)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:33)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:273)
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:234)
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:246)
... 5 more
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.DefaultExecutionDeployer.lambda$assignResource$4(DefaultExecutionDeployer.java:226)
... 37 more
Caused by: java.util.concurrent.CompletionException:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
at
java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:332)
at
java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:347)
at
java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:636)
... 35 more
Caused by:
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException:
Could not acquire the minimum required resources.
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
