这与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.
这意味着,我将不得不监视我的作业内存,并将不得不触发手动重燃。这些方法能解决这个问题吗。
发布于 2018-07-09 12:48:34
从1.5开始,Flink并不支持你想要的。重新调整作业规模的过程是:
initialParallelism
和maxParallelism maxParallelism
启动作业。initialParallelism <= parallelism <= maxParallelism
重新运行它。发布于 2018-07-10 02:37:59
您仍然需要监视您的应用程序,但是通过运行以下命令可以很容易地完成重新标度:
./bin/flink modify -p <NEW-PARALLELISM>
https://stackoverflow.com/questions/51240346
复制相似问题