flink 问题总结(15)Triggering a savepoint for the job failed.java.util.concurrent.TimeoutException

背景:

bin/flink savepoint 162f59ee8c59f1617a1cf638e3640858 --target kubernetes-application -Dkubernetes.cluster-id=test -Dkubernetes.namespace=bigdata

k8s上提交savepoint 执行命令,任务报错

org.apache.flink.util.FlinkException: Triggering a savepoint for the job 162f59ee8c59f1617a1cf638e3640858 failed.
  at org.apache.flink.client.cli.CliFrontend.triggerSavepoint(CliFrontend.java:777)
  at org.apache.flink.client.cli.CliFrontend.lambda$savepoint$9(CliFrontend.java:754)
 at org.apache.flink.client.cli.CliFrontend.runClusterAction(CliFrontend.java:1002)
  at org.apache.flink.client.cli.CliFrontend.savepoint(CliFrontend.java:751)
at org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1072)
at org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1132)
at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
  at org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1132)
Caused by: java.util.concurrent.TimeoutException
  at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1771)
  at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915)
  at org.apache.flink.client.cli.CliFrontend.triggerSavepoint(CliFrontend.java:771)
  ... 7 more

解决办法:

提交任务时增加如下配置,或修改flink-conf.yaml文件

akka.client.timeout: 300000

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容