You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Jark Wu (JIRA)" <ji...@apache.org> on 2019/08/02 02:58:00 UTC

[jira] [Created] (FLINK-13544) Set parallelism of table sink operator to input transformation parallelism

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)