美文网首页
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