[
https://issues.apache.org/jira/browse/FLINK-38402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18029459#comment-18029459
]
Zakelly Lan commented on FLINK-38402:
-------------------------------------
The error log:
{code:java}
04:42:38,158 [ Checkpoint Timer] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering
checkpoint 132 (type=CheckpointType{name='Checkpoint',
sharingFilesStrategy=FORWARD_BACKWARD}) @ 1759984958157 for job
016f9011323742910d6681a28536d9c1.
04:42:38,195 [jobmanager-io-thread-1] WARN
org.apache.flink.runtime.jobmaster.JobMaster [] - Error while
processing AcknowledgeCheckpoint message
java.lang.IllegalStateException: Attempt to reference unknown state:
525e0fb0-bd67-3b89-84ee-feede17a755a
at
org.apache.flink.util.Preconditions.checkState(Preconditions.java:193)
~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.state.SharedStateRegistryImpl.registerReference(SharedStateRegistryImpl.java:97)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.state.SharedStateRegistry.registerReference(SharedStateRegistry.java:54)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle.registerSharedStates(IncrementalRemoteKeyedStateHandle.java:289)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.OperatorSubtaskState.registerSharedState(OperatorSubtaskState.java:248)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.OperatorSubtaskState.registerSharedStates(OperatorSubtaskState.java:224)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.TaskStateSnapshot.registerSharedStates(TaskStateSnapshot.java:193)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveAcknowledgeMessage(CheckpointCoordinator.java:1246)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$acknowledgeCheckpoint$2(ExecutionGraphHandler.java:109)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.ExecutionGraphHandler.lambda$processCheckpointCoordinatorMessage$4(ExecutionGraphHandler.java:139)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.util.MdcUtils.lambda$wrapRunnable$1(MdcUtils.java:70)
~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[?:?]
at java.base/java.lang.Thread.run(Thread.java:833) [?:?]
04:42:39,374 [Source: Custom Source (1/1)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] - Source:
Custom Source (1/1)#1
(44ca439423342499d3d88a32ead805f5_bc764cd8ddf7a0cff126f51c16239658_0_1)
switched from RUNNING to FINISHED.
04:42:39,374 [Source: Custom Source (1/1)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for Source: Custom Source (1/1)#1
(44ca439423342499d3d88a32ead805f5_bc764cd8ddf7a0cff126f51c16239658_0_1).
04:42:39,374 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state FINISHED to JobManager
for task Source: Custom Source (1/1)#1
44ca439423342499d3d88a32ead805f5_bc764cd8ddf7a0cff126f51c16239658_0_1.
04:42:39,375 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Custom Source (1/1)
(44ca439423342499d3d88a32ead805f5_bc764cd8ddf7a0cff126f51c16239658_0_1)
switched from RUNNING to FINISHED.
04:42:39,376 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Triggering a
manual checkpoint for job 016f9011323742910d6681a28536d9c1.
04:52:38,158 [ Checkpoint Timer] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Checkpoint
132 of job 016f9011323742910d6681a28536d9c1 expired before completing.
04:52:38,159 [ Checkpoint Timer] WARN
org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to
trigger or complete checkpoint 132 for job 016f9011323742910d6681a28536d9c1. (0
consecutive failed attempts so far)
org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint expired
before completing.
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator$CheckpointCanceller.run(CheckpointCoordinator.java:2340)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.util.MdcUtils.lambda$wrapRunnable$1(MdcUtils.java:70)
~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
[?:?]
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
[?:?]
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
[?:?]
at java.base/java.lang.Thread.run(Thread.java:833) [?:?]
04:52:38,160 [ Checkpoint Timer] INFO
org.apache.flink.runtime.checkpoint.CheckpointRequestDecider [] - checkpoint
request time in queue: 598784
04:52:38,161 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Trying to
recover from a global failure.
org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint tolerable
failure threshold. The latest checkpoint failed due to Checkpoint expired
before completing., view the Checkpoint History tab or the Job Manager log to
find out why continuous checkpoints failed.
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.checkFailureAgainstCounter(CheckpointFailureManager.java:212)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.handleJobLevelCheckpointException(CheckpointFailureManager.java:169)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.handleCheckpointException(CheckpointFailureManager.java:122)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:2275)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:2254)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator$CheckpointCanceller.run(CheckpointCoordinator.java:2340)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.util.MdcUtils.lambda$wrapRunnable$1(MdcUtils.java:70)
~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
~[?:?]
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
~[?:?]
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
~[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
~[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
~[?:?]
at java.base/java.lang.Thread.run(Thread.java:833) ~[?:?]
04:52:38,162 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Tumbling
Window Test (016f9011323742910d6681a28536d9c1) switched from state RUNNING to
FAILING.
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)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.handleFailureAndReport(ExecutionFailureHandler.java:163)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.getGlobalFailureHandlingResult(ExecutionFailureHandler.java:137)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleGlobalFailure(DefaultScheduler.java:337)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyGlobalFailure(UpdateSchedulerNgOnInternalFailuresListener.java:57)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.failGlobal(DefaultExecutionGraph.java:1142)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph$1.lambda$failJob$0(DefaultExecutionGraph.java:494)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRunAsync$4(PekkoRpcActor.java:460)
~[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRunAsync(PekkoRpcActor.java:460)
~[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:225)
~[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:88)
~[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:174)
~[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:272)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:233)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:245)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373) [?:?]
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
[?:?]
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655) [?:?]
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
[?:?]
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
[?:?]
Caused by: org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint
tolerable failure threshold. The latest checkpoint failed due to Checkpoint
expired before completing., view the Checkpoint History tab or the Job Manager
log to find out why continuous checkpoints failed.
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.checkFailureAgainstCounter(CheckpointFailureManager.java:212)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.handleJobLevelCheckpointException(CheckpointFailureManager.java:169)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.handleCheckpointException(CheckpointFailureManager.java:122)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:2275)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:2254)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator$CheckpointCanceller.run(CheckpointCoordinator.java:2340)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.util.MdcUtils.lambda$wrapRunnable$1(MdcUtils.java:70)
~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
~[?:?]
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
~[?:?]
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
~[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
~[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
~[?:?]
at java.base/java.lang.Thread.run(Thread.java:833) ~[?:?]
04:52:38,163 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution
44ca439423342499d3d88a32ead805f5_bc764cd8ddf7a0cff126f51c16239658_0_1.
04:52:38,164 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
SlidingEventTimeWindows (1/4)
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_0_1)
switched from RUNNING to CANCELING.
04:52:38,164 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
SlidingEventTimeWindows (2/4)
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_1_1)
switched from RUNNING to CANCELING.
04:52:38,164 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
SlidingEventTimeWindows (3/4)
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_2_1)
switched from RUNNING to CANCELING.
04:52:38,164 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
SlidingEventTimeWindows (4/4)
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_3_1)
switched from RUNNING to CANCELING.
04:52:38,164 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Sink: Unnamed
(1/1) (44ca439423342499d3d88a32ead805f5_ea632d67b7d595e5b851708ae9ad79d6_0_1)
switched from RUNNING to CANCELING.
04:52:38,165 [ Checkpoint Timer] INFO
org.apache.flink.runtime.checkpoint.CheckpointFailureManager [] - Failed to
trigger checkpoint for job 016f9011323742910d6681a28536d9c1 since Checkpoint
triggering task SlidingEventTimeWindows (1/4) of job
016f9011323742910d6681a28536d9c1 is not being executed at the moment. Aborting
checkpoint. Failure reason: Not all required tasks are currently running..
04:52:38,165 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskmanager.Task [] - Attempting to
cancel task SlidingEventTimeWindows (2/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_1_1).
04:52:38,165 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskmanager.Task [] -
SlidingEventTimeWindows (2/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_1_1)
switched from RUNNING to CANCELING.
04:52:38,165 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskmanager.Task [] - Triggering
cancellation of task code SlidingEventTimeWindows (2/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_1_1).
04:52:38,166 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task [] - Attempting to
cancel task SlidingEventTimeWindows (1/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_0_1).
04:52:38,166 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task [] -
SlidingEventTimeWindows (1/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_0_1)
switched from RUNNING to CANCELING.
04:52:38,166 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task [] - Triggering
cancellation of task code SlidingEventTimeWindows (1/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_0_1).
04:52:38,166 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskmanager.Task [] - Attempting to
cancel task SlidingEventTimeWindows (3/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_2_1).
04:52:38,166 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskmanager.Task [] -
SlidingEventTimeWindows (3/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_2_1)
switched from RUNNING to CANCELING.
04:52:38,166 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskmanager.Task [] - Triggering
cancellation of task code SlidingEventTimeWindows (3/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_2_1).
04:52:38,167 [SlidingEventTimeWindows (2/4)#1] INFO
org.apache.flink.state.rocksdb.RocksDBKeyedStateBackend [] - Closed
RocksDB State Backend. Cleaning up RocksDB working directory
/tmp/junit16442770661841230383/junit4388131450508005250/job_016f9011323742910d6681a28536d9c1_op_WindowOperator_0a448493b4782967b150582570326227__2_4__uuid_30360330-8cfc-4071-808a-905c33ef330b.
04:52:38,168 [Channel state writer] INFO
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl
[] - discarding 1 drained requests
04:52:38,168 [SlidingEventTimeWindows (3/4)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] -
SlidingEventTimeWindows (3/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_2_1)
switched from CANCELING to CANCELED.
04:52:38,170 [SlidingEventTimeWindows (3/4)#1] INFO
org.apache.flink.state.rocksdb.RocksDBKeyedStateBackend [] - Closed
RocksDB State Backend. Cleaning up RocksDB working directory
/tmp/junit16442770661841230383/junit4388131450508005250/job_016f9011323742910d6681a28536d9c1_op_WindowOperator_0a448493b4782967b150582570326227__3_4__uuid_e9805415-f662-4bb6-b30c-2195dc966d35.
04:52:38,173 [SlidingEventTimeWindows (2/4)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] -
SlidingEventTimeWindows (2/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_1_1)
switched from CANCELING to CANCELED.
04:52:38,173 [SlidingEventTimeWindows (2/4)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for SlidingEventTimeWindows (2/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_1_1).
04:52:38,173 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state CANCELED to JobManager
for task SlidingEventTimeWindows (2/4)#1
44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_1_1.
04:52:38,173 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
SlidingEventTimeWindows (2/4)
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_1_1)
switched from CANCELING to CANCELED.
04:52:38,173 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task [] - Attempting to
cancel task SlidingEventTimeWindows (4/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_3_1).
04:52:38,174 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task [] -
SlidingEventTimeWindows (4/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_3_1)
switched from RUNNING to CANCELING.
04:52:38,174 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task [] - Triggering
cancellation of task code SlidingEventTimeWindows (4/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_3_1).
04:52:38,176 [SlidingEventTimeWindows (1/4)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] -
SlidingEventTimeWindows (1/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_0_1)
switched from CANCELING to CANCELED.
04:52:38,176 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task [] - Attempting to
cancel task Sink: Unnamed (1/1)#1
(44ca439423342499d3d88a32ead805f5_ea632d67b7d595e5b851708ae9ad79d6_0_1).
04:52:38,176 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task [] - Sink: Unnamed
(1/1)#1 (44ca439423342499d3d88a32ead805f5_ea632d67b7d595e5b851708ae9ad79d6_0_1)
switched from RUNNING to CANCELING.
04:52:38,176 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskmanager.Task [] - Triggering
cancellation of task code Sink: Unnamed (1/1)#1
(44ca439423342499d3d88a32ead805f5_ea632d67b7d595e5b851708ae9ad79d6_0_1).
04:52:38,176 [Channel state writer] INFO
org.apache.flink.runtime.checkpoint.channel.ChannelStateWriteRequestExecutorImpl
[] - discarding 1 drained requests
04:52:38,176 [Sink: Unnamed (1/1)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] - Sink: Unnamed
(1/1)#1 (44ca439423342499d3d88a32ead805f5_ea632d67b7d595e5b851708ae9ad79d6_0_1)
switched from CANCELING to CANCELED.
04:52:38,177 [Sink: Unnamed (1/1)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for Sink: Unnamed (1/1)#1
(44ca439423342499d3d88a32ead805f5_ea632d67b7d595e5b851708ae9ad79d6_0_1).
04:52:38,178 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state CANCELED to JobManager
for task Sink: Unnamed (1/1)#1
44ca439423342499d3d88a32ead805f5_ea632d67b7d595e5b851708ae9ad79d6_0_1.
04:52:38,178 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Sink: Unnamed
(1/1) (44ca439423342499d3d88a32ead805f5_ea632d67b7d595e5b851708ae9ad79d6_0_1)
switched from CANCELING to CANCELED.
04:52:38,179 [SlidingEventTimeWindows (4/4)#1] INFO
org.apache.flink.state.rocksdb.RocksDBKeyedStateBackend [] - Closed
RocksDB State Backend. Cleaning up RocksDB working directory
/tmp/junit16442770661841230383/junit4388131450508005250/job_016f9011323742910d6681a28536d9c1_op_WindowOperator_0a448493b4782967b150582570326227__4_4__uuid_7610d633-9757-4ebe-8754-d1ccbffa64ca.
04:52:38,179 [SlidingEventTimeWindows (1/4)#1] INFO
org.apache.flink.state.rocksdb.RocksDBKeyedStateBackend [] - Closed
RocksDB State Backend. Cleaning up RocksDB working directory
/tmp/junit16442770661841230383/junit4388131450508005250/job_016f9011323742910d6681a28536d9c1_op_WindowOperator_0a448493b4782967b150582570326227__1_4__uuid_0f34e5b6-5946-403a-a6ab-940e4d41bc80.
04:52:38,181 [SlidingEventTimeWindows (1/4)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for SlidingEventTimeWindows (1/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_0_1).
04:52:38,182 [SlidingEventTimeWindows (3/4)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for SlidingEventTimeWindows (3/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_2_1).
04:52:38,182 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state CANCELED to JobManager
for task SlidingEventTimeWindows (1/4)#1
44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_0_1.
04:52:38,182 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state CANCELED to JobManager
for task SlidingEventTimeWindows (3/4)#1
44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_2_1.
04:52:38,182 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
SlidingEventTimeWindows (1/4)
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_0_1)
switched from CANCELING to CANCELED.
04:52:38,182 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
SlidingEventTimeWindows (3/4)
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_2_1)
switched from CANCELING to CANCELED.
04:52:38,186 [SlidingEventTimeWindows (4/4)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] -
SlidingEventTimeWindows (4/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_3_1)
switched from CANCELING to CANCELED.
04:52:38,186 [SlidingEventTimeWindows (4/4)#1] INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for SlidingEventTimeWindows (4/4)#1
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_3_1).
04:52:38,186 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state CANCELED to JobManager
for task SlidingEventTimeWindows (4/4)#1
44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_3_1.
04:52:38,186 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
SlidingEventTimeWindows (4/4)
(44ca439423342499d3d88a32ead805f5_0a448493b4782967b150582570326227_3_1)
switched from CANCELING to CANCELED.
04:52:38,186 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Tumbling
Window Test (016f9011323742910d6681a28536d9c1) switched from state FAILING to
FAILED.
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)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.handleFailureAndReport(ExecutionFailureHandler.java:163)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.ExecutionFailureHandler.getGlobalFailureHandlingResult(ExecutionFailureHandler.java:137)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleGlobalFailure(DefaultScheduler.java:337)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyGlobalFailure(UpdateSchedulerNgOnInternalFailuresListener.java:57)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.failGlobal(DefaultExecutionGraph.java:1142)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph$1.lambda$failJob$0(DefaultExecutionGraph.java:494)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.lambda$handleRunAsync$4(PekkoRpcActor.java:460)
~[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.concurrent.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRunAsync(PekkoRpcActor.java:460)
~[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleRpcMessage(PekkoRpcActor.java:225)
~[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.rpc.pekko.FencedPekkoRpcActor.handleRpcMessage(FencedPekkoRpcActor.java:88)
~[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.rpc.pekko.PekkoRpcActor.handleMessage(PekkoRpcActor.java:174)
~[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:33)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:175)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:176)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.actor.Actor.aroundReceive(Actor.scala:547)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.actor.Actor.aroundReceive$(Actor.scala:545)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
org.apache.pekko.actor.AbstractActor.aroundReceive(AbstractActor.scala:229)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.actor.ActorCell.receiveMessage(ActorCell.scala:590)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.actor.ActorCell.invoke(ActorCell.scala:557)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.dispatch.Mailbox.processMailbox(Mailbox.scala:272)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:233)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:245)
[flink-rpc-akkab60457fb-be2b-4138-b67f-b5ee9d434337.jar:2.2-SNAPSHOT]
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373) [?:?]
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
[?:?]
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655) [?:?]
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
[?:?]
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
[?:?]
Caused by: org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint
tolerable failure threshold. The latest checkpoint failed due to Checkpoint
expired before completing., view the Checkpoint History tab or the Job Manager
log to find out why continuous checkpoints failed.
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.checkFailureAgainstCounter(CheckpointFailureManager.java:212)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.handleJobLevelCheckpointException(CheckpointFailureManager.java:169)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.handleCheckpointException(CheckpointFailureManager.java:122)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:2275)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:2254)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator$CheckpointCanceller.run(CheckpointCoordinator.java:2340)
~[flink-runtime-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
org.apache.flink.util.MdcUtils.lambda$wrapRunnable$1(MdcUtils.java:70)
~[flink-core-2.2-SNAPSHOT.jar:2.2-SNAPSHOT]
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
~[?:?]
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
~[?:?]
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
~[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
~[?:?]
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
~[?:?]
at java.base/java.lang.Thread.run(Thread.java:833) ~[?:?]
04:52:38,187 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Stopping
checkpoint coordinator for job 016f9011323742910d6681a28536d9c1.
04:52:38,190 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Job
016f9011323742910d6681a28536d9c1 reached terminal state FAILED.
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.getGlobalFailureHandlingResult(ExecutionFailureHandler.java:137)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleGlobalFailure(DefaultScheduler.java:337)
at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyGlobalFailure(UpdateSchedulerNgOnInternalFailuresListener.java:57)
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.failGlobal(DefaultExecutionGraph.java:1142)
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph$1.lambda$failJob$0(DefaultExecutionGraph.java:494)
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:33)
at
org.apache.pekko.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:29)
at scala.PartialFunction.applyOrElse(PartialFunction.scala:127)
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:126)
at
org.apache.pekko.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:29)
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:272)
at org.apache.pekko.dispatch.Mailbox.run(Mailbox.scala:233)
at org.apache.pekko.dispatch.Mailbox.exec(Mailbox.scala:245)
at
java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
at
java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
at
java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
at
java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
at
java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
Caused by: org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint
tolerable failure threshold. The latest checkpoint failed due to Checkpoint
expired before completing., view the Checkpoint History tab or the Job Manager
log to find out why continuous checkpoints failed.
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.checkFailureAgainstCounter(CheckpointFailureManager.java:212)
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.handleJobLevelCheckpointException(CheckpointFailureManager.java:169)
at
org.apache.flink.runtime.checkpoint.CheckpointFailureManager.handleCheckpointException(CheckpointFailureManager.java:122)
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:2275)
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.abortPendingCheckpoint(CheckpointCoordinator.java:2254)
at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator$CheckpointCanceller.run(CheckpointCoordinator.java:2340)
at
org.apache.flink.util.MdcUtils.lambda$wrapRunnable$1(MdcUtils.java:70)
at
java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at
java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
at
java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at
java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)
04:52:38,191 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Stopping the
JobMaster for job 'Tumbling Window Test' (016f9011323742910d6681a28536d9c1).
04:52:38,191 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore [] -
Shutting down
04:52:38,193 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool [] -
Releasing slot [423f4c9fa6575f7afc1188bed280cf61].
04:52:38,193 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool [] -
Releasing slot [9877936e937bdbba896b147c91f00ee9].
04:52:38,193 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:3, state:ACTIVE, resource profile:
ResourceProfile{taskHeapMemory=512.000gb (549755813888 bytes),
taskOffHeapMemory=512.000gb (549755813888 bytes), managedMemory=64.000mb
(67108864 bytes), networkMemory=32.000mb (33554432 bytes)}, allocationId:
423f4c9fa6575f7afc1188bed280cf61, jobId: 016f9011323742910d6681a28536d9c1).
04:52:38,193 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Disconnect
TaskExecutor 0e7ad473-ff61-49a5-a0d8-4530824f3591 because: Stopping JobMaster
for job 'Tumbling Window Test' (016f9011323742910d6681a28536d9c1).
04:52:38,193 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool [] -
Releasing slot [a1dbcf30c03b51583880cf3da2facf8d].
04:52:38,193 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool [] -
Releasing slot [63c833f26243e70f2289239c4531b18d].
04:52:38,193 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Disconnect
TaskExecutor fbed969c-873d-430e-ad07-b5c44fffaf27 because: Stopping JobMaster
for job 'Tumbling Window Test' (016f9011323742910d6681a28536d9c1).
04:52:38,193 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Close
ResourceManager connection d3537ee203518c58a7f5503d2a48ed79: Stopping JobMaster
for job 'Tumbling Window Test' (016f9011323742910d6681a28536d9c1).
04:52:38,194 [ main] INFO
org.apache.flink.test.util.MiniClusterWithClientResource [] - Finalization
triggered: Cluster shutdown is going to be initiated.
04:52:38,194 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:2, state:ACTIVE, resource profile:
ResourceProfile{taskHeapMemory=512.000gb (549755813888 bytes),
taskOffHeapMemory=512.000gb (549755813888 bytes), managedMemory=64.000mb
(67108864 bytes), networkMemory=32.000mb (33554432 bytes)}, allocationId:
9877936e937bdbba896b147c91f00ee9, jobId: 016f9011323742910d6681a28536d9c1).
04:52:38,196 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Remove job
016f9011323742910d6681a28536d9c1 from job leader monitoring.
04:52:38,196 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Close
JobManager connection for job 016f9011323742910d6681a28536d9c1.
04:52:38,197 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:2, state:ACTIVE, resource profile:
ResourceProfile{taskHeapMemory=512.000gb (549755813888 bytes),
taskOffHeapMemory=512.000gb (549755813888 bytes), managedMemory=64.000mb
(67108864 bytes), networkMemory=32.000mb (33554432 bytes)}, allocationId:
a1dbcf30c03b51583880cf3da2facf8d, jobId: 016f9011323742910d6681a28536d9c1).
04:52:38,198 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:3, state:ACTIVE, resource profile:
ResourceProfile{taskHeapMemory=512.000gb (549755813888 bytes),
taskOffHeapMemory=512.000gb (549755813888 bytes), managedMemory=64.000mb
(67108864 bytes), networkMemory=32.000mb (33554432 bytes)}, allocationId:
63c833f26243e70f2289239c4531b18d, jobId: 016f9011323742910d6681a28536d9c1).
04:52:38,199 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Remove job
016f9011323742910d6681a28536d9c1 from job leader monitoring.
04:52:38,199 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Close
JobManager connection for job 016f9011323742910d6681a28536d9c1.
04:52:38,199 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
Disconnect job manager
bd5fdb7c01cf1d2f61908db374794108@pekko://flink/user/rpc/jobmanager_119 for job
016f9011323742910d6681a28536d9c1 from the resource manager.
04:52:38,199 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DefaultSlotStatusSyncer []
- Freeing slot 423f4c9fa6575f7afc1188bed280cf61.
04:52:38,199 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DefaultSlotStatusSyncer []
- Freeing slot 9877936e937bdbba896b147c91f00ee9.
04:52:38,199 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DefaultSlotStatusSyncer []
- Freeing slot a1dbcf30c03b51583880cf3da2facf8d.
04:52:38,199 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.DefaultSlotStatusSyncer []
- Freeing slot 63c833f26243e70f2289239c4531b18d.
04:52:38,202 [ main] INFO
org.apache.flink.runtime.minicluster.MiniCluster [] - Shutting down
Flink Mini Cluster
04:52:38,202 [ main] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Shutting down
rest endpoint.
04:52:38,202 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Stopping
TaskExecutor pekko://flink/user/rpc/taskmanager_115.
04:52:38,202 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Close
ResourceManager connection d3537ee203518c58a7f5503d2a48ed79.
04:52:38,202 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.state.TaskExecutorStateChangelogStoragesManager [] -
Shutting down TaskExecutorStateChangelogStoragesManager.
04:52:38,202 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.state.TaskExecutorChannelStateExecutorFactoryManager
[] - Shutting down TaskExecutorChannelStateExecutorFactoryManager.
04:52:38,203 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Stopping
TaskExecutor pekko://flink/user/rpc/taskmanager_116.
04:52:38,203 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Close
ResourceManager connection d3537ee203518c58a7f5503d2a48ed79.
04:52:38,203 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.state.TaskExecutorStateChangelogStoragesManager [] -
Shutting down TaskExecutorStateChangelogStoragesManager.
04:52:38,203 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.state.TaskExecutorChannelStateExecutorFactoryManager
[] - Shutting down TaskExecutorChannelStateExecutorFactoryManager.
04:52:38,203 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Stop job
leader service.
04:52:38,203 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager [] -
Shutting down TaskExecutorLocalStateStoresManager.
04:52:38,203 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.io.disk.FileChannelManagerImpl [] -
FileChannelManager removed spill file directory
/tmp/junit6653902172981396921/junit5062915932061227284/flink-io-ce4f705c-5f35-459b-b80e-90a63a1fcbe4
04:52:38,203 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.io.network.NettyShuffleEnvironment [] - Shutting down
the network environment and its components.
04:52:38,205 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Stop job
leader service.
04:52:38,205 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager [] -
Shutting down TaskExecutorLocalStateStoresManager.
04:52:38,207 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.disk.FileChannelManagerImpl [] -
FileChannelManager removed spill file directory
/tmp/junit6653902172981396921/junit5062915932061227284/flink-io-b8e788be-f934-4636-b50b-12edd2a07ad4
04:52:38,207 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.network.NettyShuffleEnvironment [] - Shutting down
the network environment and its components.
04:52:38,207 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.io.network.netty.NettyClient [] - Successful
shutdown (took 3 ms).
04:52:38,208 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.io.network.netty.NettyServer [] - Successful
shutdown (took 0 ms).
04:52:38,208 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.io.disk.FileChannelManagerImpl [] -
FileChannelManager removed spill file directory
/tmp/junit6653902172981396921/junit5062915932061227284/flink-netty-shuffle-286747a7-5939-4eed-b9f0-623283f7ed34
04:52:38,208 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.KvStateService [] - Shutting down
the kvState service and its components.
04:52:38,208 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Stop job
leader service.
04:52:38,209 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.filecache.FileCache [] - removed file
cache directory
/tmp/junit6653902172981396921/junit5062915932061227284/flink-dist-cache-566be7c2-868b-435f-afcf-dc01f7a0a87b
04:52:38,209 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Stopped
TaskExecutor pekko://flink/user/rpc/taskmanager_115.
04:52:38,209 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.network.netty.NettyClient [] - Successful
shutdown (took 2 ms).
04:52:38,209 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.network.netty.NettyServer [] - Successful
shutdown (took 0 ms).
04:52:38,209 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.io.disk.FileChannelManagerImpl [] -
FileChannelManager removed spill file directory
/tmp/junit6653902172981396921/junit5062915932061227284/flink-netty-shuffle-c83575ce-0880-44f6-af91-8944cc39f306
04:52:38,209 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.KvStateService [] - Shutting down
the kvState service and its components.
04:52:38,209 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Stop job
leader service.
04:52:38,209 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Closing
TaskExecutor connection fbed969c-873d-430e-ad07-b5c44fffaf27 because: The
TaskExecutor is shutting down.
04:52:38,209 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager []
- Unregistering task executor 8abe98e5e90a11b79c00823937d48dda from the slot
manager.
04:52:38,210 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Closing
TaskExecutor connection 0e7ad473-ff61-49a5-a0d8-4530824f3591 because: The
TaskExecutor is shutting down.
04:52:38,210 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager []
- Unregistering task executor b8bb9dcfb117d105af3ffe5e07a4305b from the slot
manager.
04:52:38,210 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.filecache.FileCache [] - removed file
cache directory
/tmp/junit6653902172981396921/junit5062915932061227284/flink-dist-cache-3d37a7b5-e55b-4009-8a2f-fe501e615d0d
04:52:38,210 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Stopped
TaskExecutor pekko://flink/user/rpc/taskmanager_116.
04:52:38,211 [ Thread-908] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Removing
cache directory /tmp/flink-web-ui
04:52:38,211 [ Thread-908] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] -
http://localhost:43339 lost leadership
04:52:38,211 [ Thread-908] INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Shut down
complete.
04:52:38,211 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Shut
down cluster because application is in CANCELED, diagnostics
DispatcherResourceManagerComponent has been closed..
04:52:38,211 [ Thread-908] INFO
org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent
[] - Closing components.
04:52:38,211 [ Thread-908] INFO
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] -
Stopping SessionDispatcherLeaderProcess.
04:52:38,211 [ Thread-908] INFO
org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] -
Stopping resource manager service.
04:52:38,211 [ pool-216-thread-1] INFO
org.apache.flink.runtime.resourcemanager.ResourceManagerServiceImpl [] -
Resource manager service is not running. Ignore revoking leadership.
04:52:38,212 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Stopping
dispatcher pekko://flink/user/rpc/dispatcher_118.
04:52:38,212 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Stopping all
currently running jobs of dispatcher pekko://flink/user/rpc/dispatcher_118.
04:52:38,212 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] -
Stopping credential renewal
04:52:38,212 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] -
Stopped credential renewal
04:52:38,212 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager []
- Closing the slot manager.
04:52:38,212 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager []
- Suspending the slot manager.
04:52:38,213 [flink-pekko.actor.default-dispatcher-5] INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Stopped
dispatcher pekko://flink/user/rpc/dispatcher_118.
04:52:38,214 [RpcService-Supervisor-Termination-Future-Executor-thread-1] INFO
org.apache.flink.runtime.rpc.pekko.PekkoRpcService [] - Stopping
Pekko RPC service.
04:52:38,217 [ flink-metrics-6] INFO
org.apache.pekko.actor.CoordinatedShutdown [] - Running
CoordinatedShutdown with reason [ActorSystemTerminateReason]
04:52:38,229 [ flink-metrics-6] INFO
org.apache.flink.runtime.rpc.pekko.PekkoRpcService [] - Stopping
Pekko RPC service.
04:52:38,229 [ flink-metrics-6] INFO
org.apache.flink.runtime.rpc.pekko.PekkoRpcService [] - Stopped Pekko
RPC service.
04:52:38,231 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.pekko.actor.CoordinatedShutdown [] - Running
CoordinatedShutdown with reason [ActorSystemTerminateReason]
04:52:38,237 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.PermanentBlobCache [] - Shutting down
BLOB cache
04:52:38,238 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.TransientBlobCache [] - Shutting down
BLOB cache
04:52:38,238 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.blob.BlobServer [] - Stopped BLOB
server at 0.0.0.0:33317
04:52:38,238 [flink-pekko.actor.default-dispatcher-7] INFO
org.apache.flink.runtime.rpc.pekko.PekkoRpcService [] - Stopped Pekko
RPC service.
04:52:38,242 [ main] ERROR
org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase [] -
{code}
There was a suspicious 'Attempt to reference unknown state:
525e0fb0-bd67-3b89-84ee-feede17a755a', which I guess may cause the checkpoint
cannot finish until expired. Any thoughts? [~roman]
> EventTimeWindowCheckpointingITCase failed in test_cron_azure tests
> ------------------------------------------------------------------
>
> Key: FLINK-38402
> URL: https://issues.apache.org/jira/browse/FLINK-38402
> Project: Flink
> Issue Type: Bug
> Components: Tests
> Affects Versions: 2.2.0
> Reporter: Ruan Hang
> Priority: Major
>
> Details:
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=69810&view=logs&j=39d5b1d5-3b41-54dc-6458-1e2ddd1cdcf3&t=115e5c38-6efb-5006-4921-5e2851da71ef
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
