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)