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-planner/src/main/java/org/apache/flink/table/planner/connectors/ExternalDynamicSink.java#L116 Best, Ron ravi_suryavanshi.yahoo.com via user <user@flink.apache.org> 于2023年8月27日周日 19:00写道： > 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 > > > >
