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

["Zhu Zhu (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-18047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Zhu Zhu closed FLINK-18047.
---------------------------
    Resolution: Won't Fix

> [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: Bug
>          Components: Connectors / FileSystem
>    Affects Versions: 1.10.0, 1.10.1
>         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
>            Priority: Major
>
> using filesystem batch write csv data to file, we set parallelism to 1, but output more than one (defaultLocalParallelism). There is no such problem when writing with streams.
>  



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