Flink運行模式分為:集群模式、單機模式
集群模式:Flink的並行度取決於配置文件中的默認值,如下如所示:
在此配置的默認值下,全局的所有算子平行度都是1,我們也可以在程序中重寫這個並行度 設置方式如下:
在本地模式下:默認的並行度為CPU核數可以執行線程數的最大值。比如:一台 8核 16線程的pc ,默認的並行度就是16,我們同樣在程序內可以設置重寫並行度,重寫方式同集群模式
Flink運行模式分為:集群模式、單機模式
集群模式:Flink的並行度取決於配置文件中的默認值,如下如所示:
在此配置的默認值下,全局的所有算子平行度都是1,我們也可以在程序中重寫這個並行度 設置方式如下:
在本地模式下:默認的並行度為CPU核數可以執行線程數的最大值。比如:一台 8核 16線程的pc ,默認的並行度就是16,我們同樣在程序內可以設置重寫並行度,重寫方式同集群模式
本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。