So the time niterval is much less than 1000 ms as you set in the code?
That's weird. Could you check the whole outputs to confirm that the content
won't be flushed by logs?
Best Regards,
Shixiong(Ryan) Zhu
2015-04-15 15:04 GMT+08:00 Shushant Arora <shushantaror...@gmail.com>:
> 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.
>>>
>>>
>>>
>>>
>>
>
