hi:
  这应该是对应的flink-conf.yaml的配置,这是一个全局的配置,并不能指定sink的并行度













--

Best,
wldd





在 2020-08-07 15:26:34,"Shengkai Fang" <fskm...@gmail.com> 写道:
>hi
>不知道 这个能不能满足你的要求
>
>tEnv.getConfig().addConfiguration(
>new Configuration()
>.set(CoreOptions.DEFAULT_PARALLELISM, 128)
>);
>
>参见文档:https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html
>
>
>wldd <wldd1...@163.com> 于2020年8月7日周五 下午3:16写道:
>
>> hi,all:
>>   请教一下,TableEnviroment在执行sql的时候如何设置sink的并行度
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>>
>> --
>>
>> Best,
>> wldd

回复