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. >> >> >> > >
