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 <revp...@enerscore.com>: > 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/#/ > >
