基于savepoint 调小并发的问题

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

基于savepoint 调小并发的问题

陈赋赟
由于资源问题,想对已运行的任务执行生成savepoint并,基于改savepoint重启并调小并发,但是查询了文档并没有看到相关调小并发的描述,所以想问一下这样是否可行?
Reply | Threaded
Open this post in threaded view
|

Re: 基于savepoint 调小并发的问题

Congxian Qiu
你好,1.2 以后可以修改并发的,可以看下这个官方文档[1],不过你需要注意一下最大并发这个值不要变,而最大并发如果没有指定是由并发数计算出来的[2]

[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/state/savepoints.html#what-happens-when-i-change-the-parallelism-of-my-program-when-restoring
[2]
https://ci.apache.org/projects/flink/flink-docs-stable/ops/production_ready.html#set-an-explicit-max-parallelism
Best,
Congxian


陈赋赟 <[hidden email]> 于2019年10月10日周四 上午11:43写道:

>
> 由于资源问题,想对已运行的任务执行生成savepoint并,基于改savepoint重启并调小并发,但是查询了文档并没有看到相关调小并发的描述,所以想问一下这样是否可行?