码迷,mamicode.com
首页 > 其他好文 > 详细

Flink中并行度相关问题

时间:2020-04-11 18:11:57      阅读:140      评论:0      收藏:0      [点我收藏+]

标签:就是   执行   png   线程   方式   cpu   配置   本地   mic   

Flink运行模式分为:集群模式、单机模式

集群模式:Flink的并行度取决于配置文件中的默认值,如下如所示:

技术图片

在此配置的默认值下,全局的所有算子平行度都是1,我们也可以在程序中重写这个并行度 设置方式如下:

技术图片

 

在本地模式下:默认的并行度为CPU核数可以执行线程数的最大值。比如:一台 8核 16线程的pc ,默认的并行度就是16,我们同样在程序内可以设置重写并行度,重写方式同集群模式

 

Flink中并行度相关问题

标签:就是   执行   png   线程   方式   cpu   配置   本地   mic   

原文地址:https://www.cnblogs.com/laogou-idea/p/12681302.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!