wuchong commented on issue #9332: [FLINK-13544][connectors] Set parallelism of table sink operator to input transformation parallelism URL: https://github.com/apache/flink/pull/9332#issuecomment-517668344 Hi @twalthr , the planner can't set parallelism for the sink because we don't know how many transformations are applied in `consumeDataStream(DataStream<T> dataStream)`. For example, `CsvTableSink` applies `CsvFormatter` -> `TextOutputFormat`, we can't touch both transformations. In the future, when we propose a new TableSource with functions, I think we can do this by planner. I think this change is safe and makes sink chained as much as possible to protect correctness.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] With regards, Apache Git Services
