Flink动态标度1.5
Flink动态标度1.5
提问于 2018-07-09 07:41:45
这与Flink 1.5中的动态重标度有关。
我使用Yarn来运行Flink作业。我从静态资源开始这些作业。是否有任何选项可以在特定情况下自行扩展这些任务，比如是否存在内存问题。
Applications can be rescaled without manually triggering a savepoint. Under the hood, Flink will still take a savepoint, stop the application, and rescale it to the new parallelism.
这意味着，我将不得不监视我的作业内存，并将不得不触发手动重燃。这些方法能解决这个问题吗。
回答 2
Stack Overflow用户
回答已采纳
发布于 2018-07-09 20:48:34
从1.5开始，Flink并不支持你想要的。重新调整作业规模的过程是：
- 使用并行性
initialParallelism和maxParallelismmaxParallelism启动作业。 - 手动停止。
- 用
initialParallelism <= parallelism <= maxParallelism重新运行它。
Stack Overflow用户
发布于 2018-07-10 10:37:59
您仍然需要监视您的应用程序，但是通过运行以下命令可以很容易地完成重新标度：
./bin/flink modify -p <NEW-PARALLELISM>页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/51240346
复制相关文章
相似问题
腾讯云开发者
