如何使用 Flink 用户配置显示应用配置（application.conf 中的值）

Posted 2023-03-04

【中文标题】如何使用 Flink 用户配置显示应用配置（application.conf 中的值）

【英文标题】：How to Use Flink User Configuration to display application configuration (values in application.conf)

【发布时间】：2021-12-08 21:01:55

【问题描述】：

我很好奇如何在 Flink Jobmanager UI 中使用这个用户配置选项。有什么方法可以让我的 application.conf 值通过 flink 环境公开并显示在用户配置中。我没有在网上找到很多关于此用户配置的文档。

如果有人对此有任何想法，请告诉我。

谢谢。

【参考方案1】：

UI 的此部分由通过ExecutionConfig#setGlobalJobParameters 设置的GlobalJobParameters 填充。

public static void main(String[] args) throws Exception 
    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

    // assemble a map of values (e.g., from 'args', a file on the classpath or the jar manifest)
    Map<String, String> data = ...
    env.getConfig().setGlobalJobParameters(new MetaData(data));

    // rest the job
    ...
    


// a trivial mapper around an existing map
private static class MetaData extends ExecutionConfig.GlobalJobParameters 
    private final Map<String, String> data;

    private MetaData(Map<String, String> data) 
        this.data = data;
    

    @Override
    public Map<String, String> toMap() 
        return data;
    

【讨论】：

成功了，谢谢。

【参考方案2】：

您可以在 JobManager -> 配置中找到您的配置