Hi Ravi,
Maybe it's due to *execution.batch.adaptive.auto-parallelism.enabled*
Option.
How about trying to configure
*execution.batch.adaptive.auto-parallelism.enabled* to *false* and apply
other parallelism.
Best,
Dongwoo
2023년 8월 27일 (일) 오후 8:00, ravi_suryavanshi.yahoo.com via user <
user@flink
Hi, Ravi
I have deep dive into the source code[1], the parallelism of the Sink
operator is consistent with its inputs, so I suggest you check the
parallelism of the upstream operators.
[1]
https://github.com/apache/flink/blob/a68dd419718b4304343c2b27dab94394c88c67b5/flink-table/flink-table-plan