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