[FLINK-18047] [DDL] ExecutotionEnvironment set the parallelism did not take effect

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Won't Fix
• Affects Version/s: 1.10.0, 1.10.1
• Component/s: Connectors / FileSystem

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',
...
)

• Assignee: Unassigned
• Reporter: pengnengsong
• Created: 01/Jun/20 07:29
• Updated: 16/Aug/20 14:16
• Resolved: 16/Aug/20 14:16

Description

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.