What port should I choose to run the SocketTextStreamWordCount sample

[Prez Cannady]

Feeling my way around Flink. I've generated the SocketTextStreamWordCount from the quickstart and discovered quickly the recommended usage

    Usage: SocketTextStreamWordCount <host> <port>

However, I have no idea what port to choose. The QuickStart docs don't reveal much, and while I suspect I need to submit the JobManager's port as an argument, I get a Connection Refused when I configure the default port (6123).

Appreciate any help or hints.

Prior research
[1] Quickstart: Scala API (https://ci.apache.org/projects/flink/flink-docs-release-0.8/scala_api_quickstart.html)
[2] Flink Setup: Configuration (https://ci.apache.org/projects/flink/flink-docs-master/setup/config.html)


Also asked at Stack Overflow.

http://stackoverflow.com/questions/34753226/what-port-should-i-choose-to-run-the-sockettextstreamwordcount-sample

Prez Cannady  
e: [hidden email]  
p: 617 500 3378
w:  http://www.enerscore.com/
d: http://demo2.enerscore.com/#/

[Fabian Hueske-2]

Hi,

I answered your question on Stack Overflow.

To summarize, the program reads data from a text socket.
You need to open the socket before starting the program. You can open the socket on any (available) port.

If you run

nc -lk 9999



from a command line, you should used localhost and port 9999.

Best, Fabian

2016-01-12 21:40 GMT+01:00 Prez Cannady <[hidden email]>:

Feeling my way around Flink. I've generated the SocketTextStreamWordCount from the quickstart and discovered quickly the recommended usage

    Usage: SocketTextStreamWordCount <host> <port>

However, I have no idea what port to choose. The QuickStart docs don't reveal much, and while I suspect I need to submit the JobManager's port as an argument, I get a Connection Refused when I configure the default port (6123).

Appreciate any help or hints.

Prior research
[1] Quickstart: Scala API (https://ci.apache.org/projects/flink/flink-docs-release-0.8/scala_api_quickstart.html)
[2] Flink Setup: Configuration (https://ci.apache.org/projects/flink/flink-docs-master/setup/config.html)


Also asked at Stack Overflow.

http://stackoverflow.com/questions/34753226/what-port-should-i-choose-to-run-the-sockettextstreamwordcount-sample

Prez Cannady
e: [hidden email]
p: <a href="tel:617%20500%203378" value="[phone]">617 500 3378
w:  http://www.enerscore.com/
d: http://demo2.enerscore.com/#/

[Prez Cannady]

Thanks.  That summed it up nicely.  I’m able to move forward now.

Prez Cannady  

e: [hidden email]  

p: 617 500 3378

w:  http://www.enerscore.com/

d: http://demo2.enerscore.com/#/

On Jan 12, 2016, at 3:54 PM, Fabian Hueske <[hidden email]> wrote:

Hi,

I answered your question on Stack Overflow.

To summarize, the program reads data from a text socket.
You need to open the socket before starting the program. You can open the socket on any (available) port.

If you run

nc -lk 9999



from a command line, you should used localhost and port 9999.

Best, Fabian

2016-01-12 21:40 GMT+01:00 Prez Cannady <[hidden email]>:

Feeling my way around Flink. I've generated the SocketTextStreamWordCount from the quickstart and discovered quickly the recommended usage

    Usage: SocketTextStreamWordCount <host> <port>

However, I have no idea what port to choose. The QuickStart docs don't reveal much, and while I suspect I need to submit the JobManager's port as an argument, I get a Connection Refused when I configure the default port (6123).

Appreciate any help or hints.

Prior research
[1] Quickstart: Scala API (https://ci.apache.org/projects/flink/flink-docs-release-0.8/scala_api_quickstart.html)
[2] Flink Setup: Configuration (https://ci.apache.org/projects/flink/flink-docs-master/setup/config.html)


Also asked at Stack Overflow.

http://stackoverflow.com/questions/34753226/what-port-should-i-choose-to-run-the-sockettextstreamwordcount-sample

Prez Cannady
e: [hidden email]
p: <a href="tel:617%20500%203378" value="[phone]" class="">617 500 3378
w:  http://www.enerscore.com/
d: http://demo2.enerscore.com/#/