Yes only Time: 1429054870000 ms strings gets printed on console.
No output is getting printed.
And timeinterval between two strings of form ( time:****ms)is very less
than Streaming Duration set in program.
On Wed, Apr 15, 2015 at 5:11 AM, Shixiong Zhu <zsxw...@gmail.com> wrote:
> Could you see something like this in the console?
>
> -------------------------------------------
> Time: 1429054870000 ms
> -------------------------------------------
>
>
> Best Regards,
> Shixiong(Ryan) Zhu
>
> 2015-04-15 2:11 GMT+08:00 Shushant Arora <shushantaror...@gmail.com>:
>
>> Hi
>>
>> I am running a spark streaming application but on console nothing is
>> getting printed.
>>
>> I am doing
>> 1.bin/spark-shell --master clusterMgrUrl
>> 2.import org.apache.spark.streaming.StreamingContext
>> import org.apache.spark.streaming.StreamingContext._
>> import org.apache.spark.streaming.dstream.DStream
>> import org.apache.spark.streaming.Duration
>> import org.apache.spark.streaming.Seconds
>> val ssc = new StreamingContext( sc, Seconds(1))
>> val lines = ssc.socketTextStream("hostname",7777)
>> lines.print()
>> ssc.start()
>> ssc.awaitTermination()
>>
>> Jobs are getting created when I see webUI but nothing gets printed on
>> console.
>>
>> I have started a nc script on hostname port 7777 and can see messages
>> typed on this port from another console.
>>
>>
>>
>> Please let me know If I am doing something wrong.
>>
>>
>>
>>
>
