如果我们通过SavePoint取消工作，Job被取消了，SavePoint是失败如何现在还原这项工作

发布于 2025-01-28 12:10:56 字数 451 浏览 1 评论 0原文

我已经使用本机Kubernetes部署并与SavePoint一起在应用程序模式下部署了Flink作业（我正在使用REST API命令），但是如果它未能完成保存点，则可以为该工作取消，因为它已经被取消了？

1) success:

{
  "status":{"id":"COMPLETED"},
  "operation":{
    "location":"file:/savepoints-dir/savepoint-ad4025-dd46c1bd1c80"
  }
}
2) failure:

{
  "status":{"id":"COMPLETED"},
  "operation":{
    "failure-cause":{
      "class": "java.util.concurrent.CompletionException",
      "stack-trace": "..."
    }
  }
}

原文

I have deployed flink job in application mode using native kubernetes deployment and stopping job along with savepoint (I'm using rest api command for that) but if it fails to complete savepoint is it possible to take savepoint for that job as it was cancelled already?

1) success:

{
  "status":{"id":"COMPLETED"},
  "operation":{
    "location":"file:/savepoints-dir/savepoint-ad4025-dd46c1bd1c80"
  }
}
2) failure:

{
  "status":{"id":"COMPLETED"},
  "operation":{
    "failure-cause":{
      "class": "java.util.concurrent.CompletionException",
      "stack-trace": "..."
    }
  }
}

分享到QQ

分享到微博