Due to the job-submission changes in 1.5 you attempted to send REST requests to akka, which causes the exception you received.

Instead you want to specify the REST port instead, which by default is 8081 (configurable via rest.port).

On 21.06.2018 10:44, chrisr123 wrote:
This looks related to using the -m option on CLI:

This works:
$FLINK_HOME/bin/flink run -c $CLASS $JARFILE

but this causes the error:
$FLINK_HOME/bin/flink run -m jobmanagermachine:6123 -c $CLASS $JARFILE


I found this thread here from April 27
http://mail-archives.apache.org/mod_mbox/flink-user/201804.mbox/%3c1524831996624-0.p...@n4.nabble.com%3E



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/


Reply via email to