文章/答案/技术大牛

发布

社区首页 >问答首页 >如何重新启动flink作业以使用添加的TaskManager

问如何重新启动flink作业以使用添加的TaskManager
EN

Stack Overflow用户

提问于 2017-06-19 15:44:12

回答 1查看 2.6K关注 0票数 1

我正在测试Flink 1.3.0中的弹性特性。我有一个具有检查点启用和固定延迟重启策略的作业.当我杀死一个TaskManager JVM时，一段时间后，作业将在剩余的节点上正确地重新启动。但是，当我添加一个新节点时，作业不会自动重新启动以利用它。

我试着使用bin/flink stop <jobId>，但它总是给我java.lang.IllegalStateException: Job with ID <jobId> is not stoppable.

如何重新启动作业以利用附加节点？

回答已采纳

发布于 2017-06-22 18:01:20

Flink 1.3不提供动态重标，也不会自动重新启动作业以利用新的可用资源。要在这种情况下重新启动作业，您应该使用保存点，增加并行性，并从保存点重新启动作业。您可以用这样的保存点取消一个工作：

flink cancel -s [targetDirectory] <jobID>

然后通过

flink run -s <savepointPath> ...

有关保存点的更多细节，请参见CLI文档和保存点文档，但您可以将保存点视为用户触发的检查点。

Apache at MediaMath:在生产中重新标定重要的应用程序是来自detail的一篇最近的博客文章，其中包含了许多关于重新缩放内部工作方式的细节。

票数 5

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/44634789

复制

相似问题

问如何重新启动flink作业以使用添加的TaskManagerEN