You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by chrisr123 <ch...@gmail.com> on 2018/06/21 04:17:00 UTC
Flink 1.5 TooLongFrameException in cluster mode?
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/
Re: Flink 1.5 TooLongFrameException in cluster mode?
Posted by Chesnay Schepler <ch...@apache.org>.
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@n4.nabble.com%3E
>
>
>
> --
> Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>
Re: Flink 1.5 TooLongFrameException in cluster mode?
Posted by chrisr123 <ch...@gmail.com>.
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@n4.nabble.com%3E
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/