我理解在Yarn上运行,通过-yD传入和写在flink-conf.yaml里面都是可以生效的
Best, Yang liangji <jiliang1...@gmail.com> 于2020年7月2日周四 下午6:12写道: > > https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table/config.html#execution-options > // instantiate table environment > TableEnvironment tEnv = ... > > // access flink configuration > Configuration configuration = tEnv.getConfig().getConfiguration(); > // set low-level key-value options > configuration.setString("table.exec.mini-batch.enabled", "true"); > configuration.setString("table.exec.mini-batch.allow-latency", "5 s"); > configuration.setString("table.exec.mini-batch.size", "5000"); > > 请问下,table的这些参数是不是只能在代码里面设置,通过 -yd 传入可否生效呢? > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >