Apache Flink 中文用户邮件列表
Search
everywhere
only in this topic
Advanced Search
基于savepoint 调小并发的问题
Classic
List
Threaded
♦
♦
Locked
2 messages
陈赋赟
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
基于savepoint 调小并发的问题
由于资源问题,想对已运行的任务执行生成savepoint并,基于改savepoint重启并调小并发,但是查询了文档并没有看到相关调小并发的描述,所以想问一下这样是否可行?
Congxian Qiu
Reply
|
Threaded
Open this post in threaded view
♦
♦
|
Re: 基于savepoint 调小并发的问题
你好,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重启并调小并发,但是查询了文档并没有看到相关调小并发的描述,所以想问一下这样是否可行?
Free forum by Nabble
Edit this page