You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Xintong Song (Jira)" <ji...@apache.org> on 2021/09/22 02:13:00 UTC
[jira] [Created] (FLINK-24350) Resuming Savepoint (hashmap, sync,
scale up) end-to-end test fails due to ask timeout
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)