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
Hi,I am trying to use the Table API which will convert the Table data into
Datastream. API is StreamTableEnvironment.toChangelogStream(Table table).I have
noticed that its parallelism is always single i.e. One (1). How can set more
than one?
If it is intended to execute with a single thread then
