hi, 现在仅支持全局设置，现在并不支持对于单个sink并行度的设置。 对于单个sink的设置社区正在讨论中，见 https://www.mail-archive.com/[email protected]/msg40251.html wldd <[email protected]> 于2020年8月7日周五 下午3:41写道：
> hi： > 这应该是对应的flink-conf.yaml的配置，这是一个全局的配置，并不能指定sink的并行度 > > > > > > > > > > > > > > -- > > Best， > wldd > > > > > > 在 2020-08-07 15:26:34，"Shengkai Fang" <[email protected]> 写道： > >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 >
