I need to submit a new Apache Flink Job from the Web GUI instanced in a docker container in Session Mode and i need to pass some arguments to the main function of my job written in Java.
I'm trying to pass these arguments using the Program Arguments field located in the Submit New Job section as shown in the image below
Passing Arguments
The thing is, Когда я пытаюсь прочитать эти аргументы из моей основной функции, массив ARGS всегда пуст, и я не могу их правильно проанализировать.public static void main(String[] args) throws Exception {
loggingObj.info("ARGS: {}", Arrays.toString(args))
// GET PARAMETERS FROM FLINK GUI
ParameterTool parameters = ParameterTool.fromArgs(args);
double windowDurationS = parameters.getDouble("windowDurationS", 5.0);
double watermarkIdlenessS = parameters.getDouble("watermarkIdlenessS",4.0);
double queryIntervalS = parameters.getDouble("queryIntervalS", 4.0);
String processingFunction = parameters.get("processingFunction", "All Supported Functions").trim();
loggingObj.info("PARAMETERS: {}", parameters.toMap());
loggingObj.info("PROCESSING FUNCTION: {}", processingFunction);
< /code>
Я также пытался изменить формат, в котором я передаю аргументы. < /p>
Я попробовал < /p>
-param1 value1
--param1 value1
param1="value1"
param1=value1
< /code>
Но ни один из них не работает. Когда я регистрирую аргументы из моего кода, список всегда пуст, как показано в журналах < /p>
INFO demoFlink.DataStreamJob [] - ARGS: []
INFO demoFlink.DataStreamJob [] - PARAMETERS: {}
INFO demoFlink.DataStreamJob. [] - PROCESSING FUNCTION: All Supported Functions
< /code>
Я также проверил точку записи моей работы, и все правильно, это всего лишь одно главное, и все остальные, кажется, работают просто отлично.
Кроме того, если я пытаюсь выполнить одну и ту же работу с аргументами, которые мне нужны локально, все в порядке.>
Подробнее здесь: https://stackoverflow.com/questions/797 ... job-proper
