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