Hello
i just started working with spark today... and i am trying to run the wordcount
network example
i created a socket server and client.. and i am sending data to the server in
an infinite loop
when i run the spark class.. i see this output in the console...
-------------------------------------------Time: 1396281891000
ms-------------------------------------------14/03/31 11:04:51 INFO
SparkContext: Job finished: take at DStream.scala:586, took 0.056794606
s14/03/31 11:04:51 INFO JobScheduler: Finished job streaming job 1396281891000
ms.0 from job set of time 1396281891000 ms14/03/31 11:04:51 INFO JobScheduler:
Total delay: 0.101 s for time 1396281891000 ms (execution: 0.058 s)14/03/31
11:04:51 INFO TaskSchedulerImpl: Remove TaskSet 3.0 from pool but i dont see
any output from the workcount operation when i make this call...
wordCounts.print();any help is greatly appreciated
thanks in advance
