TableEnvironment中怎么添加参数，使参数能在TaskManagerServices中能获取到？

Tue, 22 Dec 2020 01:54:27 -0800 

Hi：
我的程序是Flink Table/SQL开发的，我想要设置参数能在TaskManagerServices中生效，怎么设置？

我使用如下设置，在TaskManagerServices中并不能获取到我设置的值。
val settings = EnvironmentSettings.newInstance()
.inBatchMode()
.build()
val tEnv = TableEnvironment.create(settings)
tEnv.getConfig.getConfiguration.set(CoreOptions.CHECK_LEAKED_CLASSLOADER,
  java.lang.Boolean.FALSE)

我能怎么设置使其能在TaskManagerServices中能生效？


-----
Thanks!

回复