flink 并行度 详细
时间: 2023-11-07 21:53:28 浏览: 91
flink详细教学
Flink 的并行度是指作业中可以同时执行的任务数量,也就是作业的并行度。Flink支持两种类型的并行度:任务并行度和算子并行度。
任务并行度是指任务被分成多个子任务并行执行的能力。在Flink中,一个任务可以被分成多个子任务并行执行,每个子任务都可以在不同的线程或计算节点上运行。任务并行度可以通过设置并行任务的数量来控制。
算子并行度是指在算子内部并行处理数据的能力。Flink中的算子可以被分成多个子任务并行执行,每个子任务都可以在不同的线程或计算节点上运行。算子并行度可以通过设置算子并行度的数量来控制。
一般来说,任务并行度和算子并行度都可以通过设置Flink作业的并行度参数来控制。在Flink中,可以通过设置作业的并行度参数来控制作业中每个算子的并行度,也可以通过设置算子的并行度参数来控制算子内部的并行度。同时,Flink也支持自适应并行度调整,即根据运行时的负载情况动态地调整并行度以提高作业的性能。
阅读全文