如何获取flink存储点id？

xjreopfe 于 2021-06-24 发布在 Flink

关注(0)|答案(1)|浏览(338)

在2个与保存点相关的rest API中：
post/jobs/：jobid/savepoints，它触发异步保存点操作并返回触发器id。
get/jobs/：jobid/savepoints/：triggerid，它通过触发器id返回操作的状态。
第一个api接受一个参数 target-directory ，但不清楚是确切的目录还是父目录，flink将在其中生成名为保存点id的子目录。根据我使用flink cli的经验，我认为它可能是父目录，但如果是这样，如何获取保存点id？在第二个api中没有记录。

apache-flink

来源：https://stackoverflow.com/questions/58510251/how-do-i-get-flink-savepoint-id

1条答案

按热度按时间

mbskvtky1#

我把答案打印出来就知道了。这里有成功和失败的例子。
1）成功：

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

2）失败：

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

赞(0）回复(0）举报 2021-06-24

我来回答

如何获取flink存储点id？

1条答案

相关问题

热门标签

最新问答