Sorry, the command is
nc -lk 12345
Thanks
Best Regards
On Fri, Jul 11, 2014 at 6:46 AM, Akhil Das <ak...@sigmoidanalytics.com>
wrote:
> You simply use the *nc* command to do this. like:
>
> nc -p 12345
>
> will open the 12345 port and from the terminal you can provide whatever
> input you require for your StreamingCode.
>
> Thanks
> Best Regards
>
>
> On Fri, Jul 11, 2014 at 2:41 AM, kytay <kaiyang....@gmail.com> wrote:
>
>> Hi
>>
>> I am learning spark streaming, and is trying out the JavaNetworkCount
>> example.
>>
>>
>> #1 - This is the code I wrote
>> JavaStreamingContext sctx = new JavaStreamingContext("local", appName, new
>> Duration(5000));
>> JavaReceiverInputDStream<String> lines =
>> sctx.socketTextStream("127.0.0.1",
>> 9999);
>>
>> JavaDStream<String> words =lines.flatMap(
>> new FlatMapFunction<String, String>() {
>> @Override
>> public Iterable<String> call(String arg0) throws
>> Exception {
>>
>> System.out.println("Print text:" + arg0);
>> return Arrays.asList(arg0.split(" "));
>> }
>> });
>>
>> #2 - This is the socketCode I am using
>> import java.io.BufferedReader;
>> import java.io.DataOutputStream;
>> import java.io.InputStreamReader;
>> import java.net.ServerSocket;
>> import java.net.Socket;
>>
>> public class TestTcpServer {
>>
>> public static void main(String argv[]) throws Exception
>> {
>> String clientSentence;
>> String capitalizedSentence;
>> ServerSocket welcomeSocket = new ServerSocket(9999);
>>
>> int i = 0;
>>
>> while(true)
>> {
>> Socket connectionSocket = welcomeSocket.accept();
>> BufferedReader inFromClient = new BufferedReader(
>> new
>> InputStreamReader(connectionSocket.getInputStream())
>> );
>> DataOutputStream outToClient = new
>> DataOutputStream(connectionSocket.getOutputStream());
>>
>> while(true)
>> {
>> String sendingStr = "Sending... data... "
>> + i;
>> outToClient.writeBytes(sendingStr);
>> System.out.println(sendingStr);
>> i++;
>> Thread.sleep(3000);
>> }
>> }
>> }
>> }
>>
>> What I am trying to do is to get the JavaNetworkCount in #1 to start
>> printing all the text I am receiving. But so far I failed to achieve that.
>>
>> I have been using Hercules Setup
>> <http://www.hw-group.com/products/hercules/details_en.html> to
>> simulate as
>> a TCP server, as well as a simple serversocket code in #2...
>> But I am not seeing any text being printed on the console.
>>
>> Is public Iterable<String> call(String arg0) throws Exception being called
>> every 5 secs?
>>
>> The console log is in http://pastebin.com/THzdzGhg
>> <http://pastebin.com/THzdzGhg>
>>
>>
>>
>> --
>> View this message in context:
>> http://apache-spark-user-list.1001560.n3.nabble.com/Streaming-Cannot-get-socketTextStream-to-receive-anything-tp9382.html
>> Sent from the Apache Spark User List mailing list archive at Nabble.com.
>>
>
>
