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