Re: Table API table2datastream (toChangelogStream)

2023-08-28 Thread Dongwoo Kim
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

Re: Table API table2datastream (toChangelogStream)

2023-08-27 Thread liu ron
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