我理解在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/
>

回复