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