Re: 不同的流程使用不同的并行度

Thu, 20 Apr 2023 18:03:59 -0700 

Hi

DataStream作业设置并发度有两种方式
1. 在ExecutionEnvironment通过setParallelism设置全局并发
2. 在DataStream中通过setParallelism为指定的datastream计算设置并发度

Best,
Shammon FY

On Fri, Apr 21, 2023 at 8:58 AM 小昌同学 <ccc0606fight...@163.com> wrote:

>
>
> 各位老师好，请教一下关于flink的并行度的问题；
> 我现在数据上游是kafka(四个分区)，经过Flink
> ETL处理后，实时落地到Kafka以及MYSQL，那我想在不同的阶段设置不同的并行度，这一块可以怎么使用，我使用的是DataStream API
> 还想请教一下就是关于并行度的这个设置，应该从哪些方面进行考虑啊，麻烦各位老师指教一下
> | |
> 小昌同学
> |
> |
> ccc0606fight...@163.com
> |

回复