TableEnvironment中怎么添加参数,使参数能在TaskManagerServices中能获取到?

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

TableEnvironment中怎么添加参数,使参数能在TaskManagerServices中能获取到?

jy l
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!