Flink 1.5 TooLongFrameException in cluster mode?

[chrisr123]

I download Flink 1.5 and I'm trying to run it in standalone mode.
1 job manager, 2 task managers.

I can run flink job when I run in local mode: 1 machine as both job manager
and task manager.
But when I add 2 remote machines as slaves and try to run, I am seeing this
error in the log and the job hangs.

2018-06-21 00:09:20,861 WARN  akka.remote.transport.netty.NettyTransport                  
- Remote connection to [/10.0.0.107:56390] failed with
org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException:
Adjusted frame length exceeds 10485760: 1195725860 - discarded

Looks like some sort of configuration problem. Any idea how to fix this?
Thanks!




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

[chrisr123]

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.post@...%3E



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

[Chesnay Schepler]

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.post@...%3E
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>