Flink中並行度相關問題


Flink運行模式分為:集群模式、單機模式

集群模式:Flink的並行度取決於配置文件中的默認值,如下如所示:

在此配置的默認值下,全局的所有算子平行度都是1,我們也可以在程序中重寫這個並行度 設置方式如下:

 

在本地模式下:默認的並行度為CPU核數可以執行線程數的最大值。比如:一台 8核 16線程的pc ,默認的並行度就是16,我們同樣在程序內可以設置重寫並行度,重寫方式同集群模式

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM