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/#/