Hi Chesnay, Now server and client/IDE both are using 1.4.0. When I submit job from IDE getting below exception,
com.typesafe.config.ConfigException$Missing: No configuration setting found for key 'akka.remote.artery' I have used shadow jar. Thought problem is with merging jars. But I could not find above property 'akka.remote.artery' in any of akka jars. Please guide. On Fri, Jul 13, 2018 at 4:03 PM Chesnay Schepler <ches...@apache.org> wrote: > FLIP-6 is/was an initiative to rework Flink distributed model. > > Contrary to my previous reply this wasn't introduced in 1.4, please > disregard explanation a). > > Thus, the only remaining explanation is that you're running 1.5 in the > client/IDE. > I heavily recommend to make sure that your client/IDE uses 1.4 > > For completeness sake, to disable FLIP-6 > * within the IDE, enable the "legacyCode" maven profile > * for the client, configure the mode > <https://ci.apache.org/projects/flink/flink-docs-release-1.5/ops/config.html#mode> > parameter. > > On 13.07.2018 12:20, Mohan mohan wrote: > > Hi, > what is flip6? "Flink Improvement Proposal" ? > How to enable/disable flip mode in below cases, > 1. While starting cluster using ./start-cluster.sh > 2. While connecting using > ExecutionEnvironment.createRemoteEnvironment("localhost", 6123, "xyz.jar") > > Thank you. > > On Thu, Jul 12, 2018 at 9:32 PM Mohan mohan <mohanatwo...@gmail.com> > wrote: > >> 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. >>>> >>>> >>>> >>> >
