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.apache.org>님이 작성: > 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 is there any impact > on scalability and performance? > > Thanks and Regards, > Ravi > > > >
