Hi devs: Currently,Flink sql does not support source/sink parallelism config.So,it will result in wasting or lacking resources in some cases. I think it is necessary to introduce configuration of source/sink parallelism in sql. From my side,i have the solution for this feature.Add parallelism config in ‘with’ properties of DDL.
Before 1.11,we can get parallelism and then set it to StreamTableSink#consumeDataStream or StreamTableSource#getDataStream After 1.11,we can get parallelism from catalogTable and then set it to transformation in CommonPhysicalTableSourceScan or CommonPhysicalSink. What do you think?
