开发者社区> 问答> 正文

table execution-options 能否通过 -yd 生效

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 传入可否生效呢?

*来自志愿者整理的flink邮件归档

展开
收起
小阿矿 2021-12-06 15:17:33 795 0
1 条回答
写回答
取消 提交回答
  • 如果你是写代码来使用TableEnvironment的,

    你要显示的在代码中塞进TableConfig中:

    Configuration configuration = tEnv.getConfig().getConfiguration();

    configuration.addAll(GlobalConfiguration.loadConfiguration());

    CC: @Yang Wang da...@gmail.com

    GlobalConfiguration是个internal的类,有没有public

    API获取对应的Configuration?

    *来自志愿者整理的flink邮件归档

    2021-12-06 16:59:41
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
Dynamic DDL Adding Structure t 立即下载
Spark SQL: Past, Present and Future 立即下载
Spark SQL:Past Present &Future 立即下载