Flink 如何指定并发

Posted 2022-09-03 @SmartSi

提示：Flink 系统性学习笔记

---

目录

• • • 1. 设置并发度
    • • 1.1 算子级别
      • 1.2 执行环境级别
      • 1.3 客户端级别
      • 1.4 系统级别
    • 2. 设置最大并发度

---

Flink 1.11

本节介绍如何在 Flink 中配置程序并发执行。一个 Flink 程序由多个 Task (transformations/operators，data sources 以及 sinks)组成。一个 Task 可以分成多个并发实例来执行，每个并发实例只处理输入数据的一个子集。一个 Task 的并发实例的个数称为并发度(parallelism)。

1. 设置并发度

在 Flink 中一个 Task 的并发度可以指定不同级别。

1.1 算子级别

单个算子，Source，Sink 都可以通过调用 setParallelism() 方法来指定并发度。如下代码所示指定算子级别的并发度