• 算子中设置setParallelism()
  • 全局设置：
    [size=1em]

    1	env.setParallelism(3);

    
    
    
  • 算子设置（部分设置）：
    [size=1em]

    1	sum(1).setParallelism(3)

    
    
    
    
• 客户端CLI设置：-p
  [size=1em]

  1	./bin/flink run -p 3

  
  
  
• 系统设置：
  
  

　　　　修改配置文件设置/conf/flink-conf.yaml的parallelism.defaul数值

      4. 最大并行度设置

• 全局设置：
  [size=1em]

  1	env.setMaxParallelism(n)

  
  
  
• 算子设置（部分设置）：
  [size=1em]

  1	sum(1).setMaxParallelism(n)

  
  
  
  默认的最大并行度是近似于operatorParallelism + (operatorParallelism / 2)，下限是127，上线是32768.
  
  

Flink配置级别：算子>全局env>CLI>配置文件 。

.setParallelism()设置的并行度需要小于.setMaxParallelism()设置的最大并行度。

• 算子中设置setParallelism()
  • 全局设置：
    [size=1em]

    1	env.setParallelism(3);

    
    
    
  • 算子设置（部分设置）：
    [size=1em]

    1	sum(1).setParallelism(3)

    
    
    
    
• 客户端CLI设置：-p
  [size=1em]

  1	./bin/flink run -p 3

  
  
  
• 系统设置：
  
  

　　　　修改配置文件设置/conf/flink-conf.yaml的parallelism.defaul数值

      4. 最大并行度设置

• 全局设置：
  [size=1em]

  1	env.setMaxParallelism(n)

  
  
  
• 算子设置（部分设置）：
  [size=1em]

  1	sum(1).setMaxParallelism(n)

  
  
  
  默认的最大并行度是近似于operatorParallelism + (operatorParallelism / 2)，下限是127，上线是32768.
  
  

Flink配置级别：算子>全局env>CLI>配置文件 。

.setParallelism()设置的并行度需要小于.setMaxParallelism()设置的最大并行度。