如何在 Apache Flink 中从命令行传递和覆盖配置属性

Question

我们为Hadoop集群提供了不同的kerberos登录身份验证密钥表。我可以传递键表路径 flink 命令行客户端而不是在 flink-conf.yml 中指定它吗？或者从不同应用程序对特定不同配置文件的任何其他方法。谢谢！

Answer 1

您可以使用

动态属性覆盖flink-conf.yaml中的配置。在运行 flink 命令(在 yarn 上(时，您可以使用这个：

bin/flink run -m yarn-cluster -yD property_name=value User_Jar

Answer 2

您可以通过按以下方式设置参数来覆盖命令行中的配置：

./bin/flink run ./examples/batch/WordCount.jar 
                     --input file:///home/user/hamlet.txt --output file:///home/u

然后，您可以使用 ParameterTool 在代码中获取此参数。

public static void main(String[] args) throws Exception {
    final ParameterTool command = ParameterTool.fromArgs(args);
    String inputFile = command.getRequired("input");
    String outputFile = command.getRequired("output");
}

引用：https://ci.apache.org/projects/flink/flink-docs-stable/ops/cli.html