Jark Wu created FLINK-13544:
-------------------------------
Summary: Set parallelism of table sink operator to input
transformation parallelism
Key: FLINK-13544
URL: https://issues.apache.org/jira/browse/FLINK-13544
Project: Flink
Issue Type: Bug
Components: Connectors / Common, Table SQL / Planner
Reporter: Jark Wu
Currently, there are a lot of {{TableSink}} connectors uses
{{dataStream.addSink()}} without {{setParallelism}} explicitly. This will use
default parallelism of the environment. However, the parallelism of input
transformation might not be env.parallelism, for example, global aggregation
has 1 parallelism. In this case, it will lead to data reorder, and result in
incorrect result.
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
