Flink 1.5.0 no more allow multiple program argument?

Posted by Siew Wai Yow on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-1-5-0-no-more-allow-multiple-program-argument-tp20817.html

Hi,

I get the following error when upgrade flink from 1.3.2 to 1.5.0 when using REST api to upload and run a jar.

{"errors":["Expected only one value [--KAFKA_IN PREBLN_O@192.168.56.120:9092, 192.168.56.121:9092, 192.168.56.122:9092/BHARTI_FL_PREBLN_O_124 --KAFKA_OUT FX_AGGR_ASCII@192.168.56.120:9092, 192.168.56.121:9092, 192.168.56.122:9092/BHARTI_FL_FX_AGGR_ASCII_181;FX_AGGREGATED@192.168.56.120:9092, 192.168.56.121:9092, 192.168.56.122:9092/BHARTI_FL_FX_AGGREGATED_181 --KAFKA_REJECT INVALID@192.168.56.120:9092, 192.168.56.121:9092, 192.168.56.122:9092/BHARTI_FL_INVALID_181 --KAFKA_AUDIT AUDIT@192.168.56.120:9092, 192.168.56.121:9092, 192.168.56.122:9092/BHARTI_FL_AUDIT_181 --KAFKA_REPROCESS REPROCESS@192.168.56.120:9092, 192.168.56.121:9092, 192.168.56.122:9092/BHARTI_FL_REPROCESS_181 --OPTION --JOB_NAME POC_BHARTI_FLINK_AGGR  --AUDIT_WINDOWS_INTERVAL_MS 5000 --STATSD_URL 192.168.56.200:8127  --STATSD_SAMPLING_DURATION 1000 --CHECK_POINT_INTERVAL 20000 --NODEID 181 --LS_SERVER LsServer --LS_TABLES Table1, Table2 --ZK_POLLING 30 --ZK_URL 192.168.56.130, 192.168.56.131, 192.168.56.132 --LS_HOSTNAME  --LS_ENABLE 0 --ZK_RETRY_COUNT 0 --ZK_RETRY_INTERVAL 0 --LS_ABORT_ON_RELOAD_FAILURE 1 --ZK_SESSION_TIMEOUT 60000 --ZK_KEEP_CONN_ALIVE 1]."]}

Seems the program-argument no more allow multiple parameter? But the document tell different story,

"From the command line arguments"

https://ci.apache.org/projects/flink/flink-docs-release-1.5/dev/best_practices.html

Apache Flink 1.5 Documentation: Best Practices ci.apache.org Almost all Flink applications, both batch and streaming, rely on external configuration parameters. They are used to specify input and output sources (like paths or addresses), system parameters (parallelism, runtime configuration), and application specific parameters (typically used within user ...

Any advice please? thank you.

Regards,

Yow