Thanks Chesnay! I guess it is related to StringJoiner(",") used in Flink 1.5 :(
From: Chesnay Schepler
Sent: Tuesday, June 19, 2018 1:44 PM
To: user@flink.apache.org
Subject: Re: Flink 1.5.0 no more allow multiple program argument?
For now you'll have
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