[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Need assistance : creating remote environment

Based on the logs your client is using the RestClusterClient, which means that the client is either
a) running 1.4 with the flip6 profile enabled
b) running 1.5.

Please ensure that both the flink versions match for client and server, and that both run/do not run in flip6 mode.

On 11.07.2018 14:26, Mohan mohan wrote:
Attached log file. (Log level : Trace)

Is this the issue ? Trying with very minimal graph (execution plan is printed in log file)

WARN  akka.remote.transport.netty.NettyTransport                    - Remote connection to [/] failed with Adjusted frame length exceeds 10485760: 1195725860 - discarded

On Wed, Jul 11, 2018 at 5:44 PM Chesnay Schepler <chesnay@xxxxxxxxxx> wrote:
Did/could you enable logging in the submitting code?

On 11.07.2018 13:57, Mohan mohan wrote:
> Hi,
> I have started flink in cluster mode.   ..flink1.4.2/bin/$
> ./ (no config changes ie., default settings)
> And trying to connect to it,
> ExecutionEnvironment.createRemoteEnvironment("localhost", 6123,
> "xxx.jar");
> I am not seeing any response, did not find anything in jobmanager log.
> Please guide how to trace the issue. Or Do we need any preconfiguration?
> In local environment everything works fine.
> Using : flink-1.4.2-bin-scala_2.11.tgz
> Thanks in advance.