我想从Jenkins那里找份工作给Flink。到目前为止，我已经知道如何提交在构建作业中创建的jar文件。现在，我想找到任何使用旧jar运行的flink作业，优雅地停止它们，然后使用我的新jar开始一个新作业。api有列出作业、取消作业和提交作业的方法。但是，似乎没有停止作业端点。关于如何使用api优雅地停止作业，有什么想法吗？
kq0g1dla1#
即使停止端点没有文档记录，但它确实存在，其行为与取消端点类似。基本上，这是flink rest api文档中缺少的一点：
DELETE
/jobs/:jobid/stop
停止工作，成功的结果是 {} . 对于那些不知道取消和停止之间的区别的人（从这里复制）：取消和停止（流）作业的区别如下：在取消呼叫时，作业中的操作员会立即收到 cancel() 方法调用以尽快取消它们。如果在cancel调用之后操作符没有停止，flink将开始周期性地中断线程，直到它停止。“stop”调用是停止正在运行的流式作业的一种更优雅的方式。stop仅适用于使用实现 StoppableFunction 接口。当用户请求停止作业时，所有源都将收到 stop() 方法调用。作业将一直运行，直到所有源正确关闭。这允许作业完成对所有机上数据的处理。
{}
cancel()
StoppableFunction
stop()
bis0qfac2#
由于我使用的是flink1.7，下面是如何取消/停止这个版本的flink作业。我已经测试过了请求路径： /jobs/{jobid} jobid—标识作业的32个字符的十六进制字符串值。请求方法：补丁查询参数：mode（可选）：指定终止模式的字符串值。支持的值为：“取消，停止”。例子 10.xx.xx.xx:50865/jobs/4c88f503005f79fde0f2d92b4ad3ade4?mode=cancel 启动时主机端口可用提交作业时，jobid可用裁判：https://ci.apache.org/projects/flink/flink-docs-release-1.7/monitoring/rest_api.html`
/jobs/{jobid}
10.xx.xx.xx:50865/jobs/4c88f503005f79fde0f2d92b4ad3ade4?mode=cancel
2条答案
按热度按时间kq0g1dla1#
即使停止端点没有文档记录，但它确实存在，其行为与取消端点类似。
基本上，这是flink rest api文档中缺少的一点：
停止作业
DELETE请求到/jobs/:jobid/stop.停止工作，成功的结果是
{}.对于那些不知道取消和停止之间的区别的人（从这里复制）：
取消和停止（流）作业的区别如下：
在取消呼叫时，作业中的操作员会立即收到
cancel()方法调用以尽快取消它们。如果在cancel调用之后操作符没有停止，flink将开始周期性地中断线程，直到它停止。“stop”调用是停止正在运行的流式作业的一种更优雅的方式。stop仅适用于使用实现
StoppableFunction接口。当用户请求停止作业时，所有源都将收到stop()方法调用。作业将一直运行，直到所有源正确关闭。这允许作业完成对所有机上数据的处理。bis0qfac2#
由于我使用的是flink1.7，下面是如何取消/停止这个版本的flink作业。
我已经测试过了
请求路径：
/jobs/{jobid}jobid—标识作业的32个字符的十六进制字符串值。请求方法：补丁
查询参数：
mode（可选）：指定终止模式的字符串值。支持的值为：“取消，停止”。
例子
10.xx.xx.xx:50865/jobs/4c88f503005f79fde0f2d92b4ad3ade4?mode=cancel启动时主机端口可用提交作业时，jobid可用
裁判：
https://ci.apache.org/projects/flink/flink-docs-release-1.7/monitoring/rest_api.html`