Re: Table Api执行sql如何设置sink并行度

Fri, 07 Aug 2020 00:27:27 -0700 

hi
不知道 这个能不能满足你的要求

tEnv.getConfig().addConfiguration(
new Configuration()
.set(CoreOptions.DEFAULT_PARALLELISM, 128)
);

参见文档：https://ci.apache.org/projects/flink/flink-docs-stable/ops/config.html


wldd <[email protected]> 于2020年8月7日周五 下午3:16写道：

> hi，all：
>   请教一下，TableEnviroment在执行sql的时候如何设置sink的并行度
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> --
>
> Best，
> wldd

回复