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: revp...@enerscore.com  
p: 617 500 3378
w:  http://www.enerscore.com/
d: http://demo2.enerscore.com/#/

Reply via email to