[
https://issues.apache.org/jira/browse/FLINK-18047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
pengnengsong updated FLINK-18047:
---------------------------------
Description:
using filesystem batch write csv data to file, we set parallelism to 1, but
output more than one. There is no such problem when writing with streams.
was:
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.
> [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. There is no such problem when writing with streams.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
