hi，Shengkai Fang，Cayden chen：
谢谢解答，这个DISCUSS应该可以解决我的问题 -- Best， wldd 在 2020-08-07 16:56:30，"Cayden chen" <1193216...@qq.com> 写道： >hi: > 你可以把sink >之前的table转成datastream，然后改变全局的为你想设置的sink并行度，再dataStream.addSink(sink)(由于这里会取全局并行度并给算子设置), > 之后把全局并行度改回去。理论上这个方法可以为每个算子设置单独并行度 > > > > >------------------ 原始邮件 ------------------ >发件人: > "user-zh" > ><fskm...@gmail.com>; >发送时间: 2020年8月7日(星期五) 下午4:35 >收件人: "user-zh"<user-zh@flink.apache.org>; > >主题: Re: Re: Table Api执行sql如何设置sink并行度 > > > >hi, 现在仅支持全局设置，现在并不支持对于单个sink并行度的设置。 > 对于单个sink的设置社区正在讨论中，见 >https://www.mail-archive.com/dev@flink.apache.org/msg40251.html >wldd <wldd1...@163.com> 于2020年8月7日周五 下午3:41写道： > >> 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 >>
