As it turned out in the application log, it could mot find yarn configuraration! not anything to do with port
Caused by: java.lang.ClassNotFoundException: org.apache.hadoop.yarn.conf.YarnConfiguration. I had installed flink *w**ithout bundled Hadoop* and my version of Hadoop is 3.1 I went back and downloaded flink built with Hadoop 2.8 and that worked Thanks Dr Mich Talebzadeh LinkedIn * https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw <https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw>* http://talebzadehmich.wordpress.com *Disclaimer:* Use it at your own risk. Any and all responsibility for any loss, damage or destruction of data or any other property which may arise from relying on this email's technical content is explicitly disclaimed. The author will in no case be liable for any monetary damages arising from such loss, damage or destruction. On Fri, 29 Jun 2018 at 14:57, Hequn Cheng <chenghe...@gmail.com> wrote: > port should be consistent. > > 1> nc -l 2219 > 2>./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 2219 > > On Fri, Jun 29, 2018 at 9:21 PM, Mich Talebzadeh < > mich.talebza...@gmail.com> wrote: > >> thanks Hequn. >> >> This the port I started with >> >> hduser@rhes75: /data6/hduser/flink-1.5.0> nc -l 2219 >> hello >> >> and as I expected I should collect from port 2219? However, I did what >> you suggested >> >> ./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 2199 >> Starting execution of program >> ------------------------------------------------------------ >> The program finished with the following exception: >> org.apache.flink.client.program.ProgramInvocationException: Could not >> retrieve the execution result. >> >> unfortunately I am getting the same error. >> >> Cheers >> >> >> >> Dr Mich Talebzadeh >> >> >> >> LinkedIn * >> https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw >> <https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw>* >> >> >> >> http://talebzadehmich.wordpress.com >> >> >> *Disclaimer:* Use it at your own risk. Any and all responsibility for >> any loss, damage or destruction of data or any other property which may >> arise from relying on this email's technical content is explicitly >> disclaimed. The author will in no case be liable for any monetary damages >> arising from such loss, damage or destruction. >> >> >> >> >> On Fri, 29 Jun 2018 at 14:11, Hequn Cheng <chenghe...@gmail.com> wrote: >> >>> Hi Mich, >>> >>> You port is not matching. Start netcat with "nc -l 2219 &", but run >>> flink job with "--port 2199". >>> >>> >>> >>> >>> On Fri, Jun 29, 2018 at 8:40 PM, Mich Talebzadeh < >>> mich.talebza...@gmail.com> wrote: >>> >>>> Hi, >>>> >>>> I have installed flink 1.5 in standalone mode and trying a basic run as >>>> per this example >>>> >>>> >>>> https://ci.apache.org/projects/flink/flink-docs-release-1.2/quickstart/setup_quickstart.html >>>> >>>> started netcat on port 2199 >>>> >>>> nc -l 2219 & >>>> >>>> Run the example >>>> >>>> ./bin/flink run examples/streaming/SocketWindowWordCount.jar --port 2199 >>>> Starting execution of program >>>> ------------------------------------------------------------ >>>> The program finished with the following exception: >>>> org.apache.flink.client.program.ProgramInvocationException: Could not >>>> retrieve the execution result. >>>> at >>>> org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:258) >>>> at >>>> org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:464) >>>> at >>>> org.apache.flink.streaming.api.environment.StreamContextEnvironment.execute(StreamContextEnvironment.java:66) >>>> at >>>> org.apache.flink.streaming.examples.socket.SocketWindowWordCount.main(SocketWindowWordCount.java:92) >>>> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) >>>> at >>>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) >>>> at >>>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) >>>> at java.lang.reflect.Method.invoke(Method.java:498) >>>> at >>>> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:528) >>>> at >>>> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:420) >>>> at >>>> org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:404) >>>> at >>>> org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:781) >>>> at >>>> org.apache.flink.client.cli.CliFrontend.runProgram(CliFrontend.java:275) >>>> at >>>> org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:210) >>>> at >>>> org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:1020) >>>> at >>>> org.apache.flink.client.cli.CliFrontend.lambda$main$9(CliFrontend.java:1096) >>>> at >>>> org.apache.flink.runtime.security.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:30) >>>> at >>>> org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1096) >>>> Caused by: org.apache.flink.runtime.client.JobSubmissionException: >>>> Failed to submit JobGraph. >>>> >>>> Appreciate any suggestions. >>>> >>>> Thanks >>>> >>>> Dr Mich Talebzadeh >>>> >>>> >>>> >>>> LinkedIn * >>>> https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw >>>> <https://www.linkedin.com/profile/view?id=AAEAAAAWh2gBxianrbJd6zP6AcPCCdOABUrV8Pw>* >>>> >>>> >>>> >>>> http://talebzadehmich.wordpress.com >>>> >>>> >>>> *Disclaimer:* Use it at your own risk. Any and all responsibility for >>>> any loss, damage or destruction of data or any other property which may >>>> arise from relying on this email's technical content is explicitly >>>> disclaimed. The author will in no case be liable for any monetary damages >>>> arising from such loss, damage or destruction. >>>> >>>> >>>> >>> >>> >
