flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Hequn Cheng <chenghe...@gmail.com>
Subject Re: First try running I am getting org.apache.flink.client.program.ProgramInvocationException: Could not retrieve the execution result.
Date Fri, 29 Jun 2018 13:57:39 GMT
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.talebzadeh@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 <chenghequn@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.talebzadeh@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.
>>>
>>>
>>>
>>
>>

Mime
View raw message