Flink什么是从集群GUI向工作提交参数的正确方法？

我的目标是通过集群GUI中的“程序参数”字段将参数传递给Flink作业的Main（）函数。 Flink什么是从集群GUI向工作提交参数的正确方法？

，并在主访问它们（理想的键名）（）函数像一些方式，以便：

public static void main(String[] args) throws Exception { 

    ParameterTool parameter = ParameterTool.fromArgs(args); 

    CustomProps props = new CustomProps (DEFAULT_PROPERTIES_FILE); 

    String kafkaAutoOffsetReset = props.getKafkaAutoOffsetReset(); 
    String cassandraClusterUrl = props.getCassandraClusterUrl(); 

    if (args.length == 1 && args[0] != null) { 

     cassandraClusterUrl = parameter.get("cassandraClusterUrl"); 
     kafkaAutoOffsetReset = parameter.get("kafkaOffset"); 
    } 

    //Other code... 

}

我已经尝试了“ParameterTool”但我没有从中得到任何东西，如果我尝试类似：

kafkaAutoOffsetReset = args[0];

它只能如果我只放了一个字，在“程序参数”字段。所以，如果我把：

blah

它说，它被设置为“胡说”，但如果我尝试任何这些：

-kafkaOffset blah 
--kafkaOffset blah 
-kafkaOffset:blah 
-kafkaOffset=blah

我什么也没得到。我知道在CLI中如何传递参数传递给一个广口瓶中的例子：

--input file:///home/user/hamlet.txt --output file:///home/user/wordcount_out

但好像有我缺少与GUI这样做的另一种方式，我失败在追捕文档与之相关。

TL; DR

什么是通过“程序参数”字段中弗林克集群GUI提交多个ARGS的正确方法，什么是访问他们在main（）函数的正确方法？

感谢您提前提供任何帮助！

来源

2017-05-03 Jicaar

想通了。这里是如何通过论证：

来源

2017-05-04 16:10:24 Jicaar

Flink什么是从集群GUI向工作提交参数的正确方法？

回答

相关问题