我的目标是通过群集GUI中的“程序参数”字段将args传递给Flink作业的Main()函数。
并以某种方式(理想情况下是按键名)在Main()函数中访问它们,例如:
我已经尝试过“ParameterTool”,但是我没有得到任何结果,如果我尝试像这样的东西:
只有当我在“程序参数”字段中仅放置一个单词时,它才起作用。因此,如果我放置:
它说它被设置为“blah”,但如果我尝试这些中的任何一个:
我什么也得不到。我知道在CLI中传递参数给jar的示例是:
但似乎我错过了使用GUI进行操作的不同方法,而且我在寻找相关文档方面没有成功。
简而言之:
在Flink Cluster GUI中通过“程序参数”字段提交多个参数的正确方法是什么?在Main()函数中访问它们的正确方法又是什么?
提前感谢您的所有帮助!
![enter image description here](https://istack.dev59.com/apwWB.webp)
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
它说它被设置为“blah”,但如果我尝试这些中的任何一个:
-kafkaOffset blah
--kafkaOffset blah
-kafkaOffset:blah
-kafkaOffset=blah
我什么也得不到。我知道在CLI中传递参数给jar的示例是:
--input file:///home/user/hamlet.txt --output file:///home/user/wordcount_out
但似乎我错过了使用GUI进行操作的不同方法,而且我在寻找相关文档方面没有成功。
简而言之:
在Flink Cluster GUI中通过“程序参数”字段提交多个参数的正确方法是什么?在Main()函数中访问它们的正确方法又是什么?
提前感谢您的所有帮助!