美文网首页
flink 问题总结(15)Triggering a savep

flink 问题总结(15)Triggering a savep

作者: ZYvette | 来源:发表于2022-01-24 16:03 被阅读0次

背景:

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

相关文章

网友评论

      本文标题:flink 问题总结(15)Triggering a savep

      本文链接:https://www.haomeiwen.com/subject/tjvbhrtx.html