Yep, that is due to version mismatch. Working fine now.
Thank you Chesnay Schepler.
On Wed, Jul 11, 2018 at 6:05 PM Chesnay Schepler <ches...@apache.org> wrote:
> 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 [/127.0.0.1:44322] failed with
> org.apache.flink.shaded.akka.org.jboss.netty.handler.codec.frame.TooLongFrameException:
> Adjusted frame length exceeds 10485760: 1195725860 - discarded
>
>
>
> On Wed, Jul 11, 2018 at 5:44 PM Chesnay Schepler <ches...@apache.org>
> 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/$
>> > ./start-cluster.sh (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.
>>
>>
>>
>
