Xintong Song created FLINK-24350:
------------------------------------
Summary: Resuming Savepoint (hashmap, sync, scale up) end-to-end
test fails due to ask timeout
Key: FLINK-24350
URL: https://issues.apache.org/jira/browse/FLINK-24350
Project: Flink
Issue Type: Bug
Components: Runtime / Coordination
Affects Versions: 1.15.0
Reporter: Xintong Song
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=24361&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=070ff179-953e-5bda-71fa-d6599415701c&l=142119
{code}
Sep 21 16:51:46 Caused by: org.apache.flink.util.SerializedThrowable:
Invocation of [RemoteRpcInvocation(null.triggerCheckpoint(ExecutionAttemptID,
long, long, CheckpointOptions))] at recipient
[akka.tcp://flink@10.1.0.216:38779/user/rpc/taskmanager_0] timed out.
Sep 21 16:51:46 at
org.apache.flink.runtime.jobmaster.RpcTaskManagerGateway.triggerCheckpoint(RpcTaskManagerGateway.java:106)
~[flink-dist_2.11-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
Sep 21 16:51:46 at
org.apache.flink.runtime.executiongraph.Execution.triggerCheckpointHelper(Execution.java:868)
~[flink-dist_2.11-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
Sep 21 16:51:46 at
org.apache.flink.runtime.executiongraph.Execution.triggerSynchronousSavepoint(Execution.java:850)
~[flink-dist_2.11-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
Sep 21 16:51:46 at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.triggerTasks(CheckpointCoordinator.java:710)
~[flink-dist_2.11-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
Sep 21 16:51:46 at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.triggerCheckpointRequest(CheckpointCoordinator.java:653)
~[flink-dist_2.11-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
Sep 21 16:51:46 at
org.apache.flink.runtime.checkpoint.CheckpointCoordinator.lambda$startTriggeringCheckpoint$6(CheckpointCoordinator.java:620)
~[flink-dist_2.11-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
Sep 21 16:51:46 at
java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:836)
~[?:1.8.0_292]
Sep 21 16:51:46 at
java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
~[?:1.8.0_292]
Sep 21 16:51:46 at
java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
~[?:1.8.0_292]
Sep 21 16:51:46 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
~[?:1.8.0_292]
Sep 21 16:51:46 at
java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_292]
Sep 21 16:51:46 at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
~[?:1.8.0_292]
Sep 21 16:51:46 at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
~[?:1.8.0_292]
Sep 21 16:51:46 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_292]
Sep 21 16:51:46 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_292]
Sep 21 16:51:46 at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_292]
Sep 21 16:51:46 Caused by: org.apache.flink.util.SerializedThrowable: Ask timed
out on
[Actor[akka.tcp://flink@10.1.0.216:38779/user/rpc/taskmanager_0#-1544322105]]
after [10000 ms]. Message of type
[org.apache.flink.runtime.rpc.messages.RemoteRpcInvocation]. A typical reason
for `AskTimeoutException` is that the recipient actor didn't send a reply.
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
