[FLINK-13544] Set parallelism of table sink operator to input transformation parallelism

• Type: Bug
• Status: Resolved
• Priority: Critical
• Resolution: Fixed
• Fix Version/s: 1.9.0
• Component/s: Connectors / Common, Table SQL / Planner
• Labels: pull-request-available
• Assignee: Jark Wu
• Reporter: Jark Wu
• Created: 02/Aug/19 02:57
• Updated: 06/Aug/19 07:23
• Resolved: 02/Aug/19 12:06

Description

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.

Issue Links

• links to: GitHub Pull Request #9332