使用保存点完成应用程序时出错

Question

我正在尝试以增量模式完成一些使用 RocksDB 状态后端的应用程序，我想保留一个保存点以在下一次执行时开始使用。每当我尝试完成时，都会显示此错误。

错误：

Caused by: java.util.concurrent.ExecutionException: 
java.util.concurrent.CompletionException: 
java.util.concurrent.CompletionException: 
org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint Coordinator is suspending.

Caused by: org.apache.flink.util.SerializedThrowable: 
java.util.concurrent.CompletionException: 
org.apache.flink.runtime.checkpoint.CheckpointException: Checkpoint Coordinator is suspending.

这就是我尝试创建此保存点的方式：

flink stop -t yarn-per-job -Dyarn.application.id=application_1619785296629_0002 6c1d387d0a863936e55e3c89cd31b72d -p s3://my-bucket/flink/savepoints/

如果这是超时问题，解决这个问题的正确方法是什么？

Answer 1

打开了一个问题。

https://issues.apache.org/jira/browse/FLINK-21028.

我用的版本(1.11.2)有这个问题

使用保存点完成应用程序时出错

Error when finishing an application with a savepoint

apache-flink

flink-streaming