You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Chesnay Schepler (JIRA)" <ji...@apache.org> on 2018/04/27 12:55:00 UTC

[jira] [Closed] (FLINK-9255) Regression - Flink CLI -m,--jobmanager option not working

     [ https://issues.apache.org/jira/browse/FLINK-9255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Chesnay Schepler closed FLINK-9255.
-----------------------------------
    Resolution: Not A Problem

In 1.5 we are changing the client to communicate via REST instead of akka. Thus, the port you usually want to specify is 8081, the same that the WebUI runs on.

The exception is caused by the client sending http messages to the port that akka listens on, which it of course cannot properly read.

> Regression - Flink CLI  -m,--jobmanager option not working
> ----------------------------------------------------------
>
>                 Key: FLINK-9255
>                 URL: https://issues.apache.org/jira/browse/FLINK-9255
>             Project: Flink
>          Issue Type: Bug
>          Components: Client
>    Affects Versions: 1.5.0
>         Environment: Local environment - Branch release-1.5
>            Reporter: Edward Rojas
>            Priority: Major
>              Labels: cli, regression
>
> Every time the flink CLI is called with the -m option to specify the jobmanager address, the CLI is stuck on "Waiting for response..." and the Jobmanager reports the following error:
> WARN akka.remote.transport.netty.NettyTransport - Remote connection to [/x.x.x.x:xxxx] failed with org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException: Adjusted frame length exceeds 10485760: 1195725860 - discarded
> The error occurs even when run locally and try something like "flink list -m localhost:6123". But "flink list" works as expected.
> I'm using the version from the "release-1.5" branch.
>  
> It seems like the commit introducing the regression is [47909f4|https://github.com/apache/flink/commit/47909f466b9c9ee1f4caf94e9f6862a21b628817]



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)