从哪方面考虑,主要根据每个算子的工作复杂性,复杂性越高自然设置越高的并发好点。 其次实际运行时,也可以根据反压情况找到瓶颈进行调整。
Shammon FY <zjur...@gmail.com> 于2023年4月21日周五 09:04写道: > > 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 > > |