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

Posted to dev@flink.apache.org by "pengnengsong (Jira)" <ji...@apache.org> on 2020/06/01 07:30:00 UTC

[jira] [Created] (FLINK-18047) [DDL] ExecutotionEnvironment set the parallelism did not take effect

pengnengsong created FLINK-18047:
------------------------------------

             Summary: [DDL] ExecutotionEnvironment set  the parallelism did not take effect
                 Key: FLINK-18047
                 URL: https://issues.apache.org/jira/browse/FLINK-18047
             Project: Flink
          Issue Type: Improvement
          Components: Connectors / FileSystem
    Affects Versions: 1.10.1, 1.10.0
         Environment: ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

EnviromentSettings streamSettings = EnviromentSetting.newInstance().useBlinkPlanner().inStreamingMode().build();

TableEnviroment tEnv = TableEnviroment.create(streamSettings);

env.setParallelism(1);

CREATE TABLE source(
...
 )WITH(
 'connector.type' = 'filesystem',
...
 )
            Reporter: pengnengsong


using filesystem batch write csv data to file, we set parallelism to 1, but output 4 files. There is no such problem when writing with streams.

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)