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

Question

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

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

谢谢。

Answer 1

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

Answer 2

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;
    }
}

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

How to Use Flink User Configuration to display application configuration (values in application.conf)

app-config

config

apache-flink