Re: 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-tp20817p20819.html

Thanks Chesnay! I guess it is related to StringJoiner(",") used in Flink 1.5 :(

---

From: Chesnay Schepler <[hidden email]>
Sent: Tuesday, June 19, 2018 1:44 PM
To: [hidden email]
Subject: Re: Flink 1.5.0 no more allow multiple program argument?

 

For now you'll have to replace all commas with some other delimiter.

On 19.06.2018 04:15, Siew Wai Yow wrote:

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 [hidden email], 192.168.56.121:9092, 192.168.56.122:9092/BHARTI_FL_PREBLN_O_124 --KAFKA_OUT [hidden email], 192.168.56.121:9092, [hidden email], 192.168.56.121:9092, 192.168.56.122:9092/BHARTI_FL_FX_AGGREGATED_181 --KAFKA_REJECT [hidden email], 192.168.56.121:9092, 192.168.56.122:9092/BHARTI_FL_INVALID_181 --KAFKA_AUDIT [hidden email], 192.168.56.121:9092, 192.168.56.122:9092/BHARTI_FL_AUDIT_181 --KAFKA_REPROCESS [hidden email], 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