Re: Spark Streaming not processing file with particular number of entries

2014-06-13 Thread praveshjain1991
n your previous reply which i would like to clarify - I am running spark in clustered mode (over a 3 node cluster). -- Thanks -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-not-processing-file-with-particular-number-of-entries-tp6694p7602.htm

Re: Spark Streaming not processing file with particular number of entries

2014-06-13 Thread Tathagata Das
iew this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-not-processing-file-with-particular-number-of-entries-tp6694p7599.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. >

Re: Spark Streaming not processing file with particular number of entries

2014-06-13 Thread praveshjain1991
cked up by the app but it is not starting the tasks that are supposed to begin. -- Thanks. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-not-processing-file-with-particular-number-of-entries-tp6694p7599.html Sent from the Apache Spark User Li

Re: Spark Streaming not processing file with particular number of entries

2014-06-13 Thread Tathagata Das
alone. > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-not-processing-file-with-particular-number-of-entries-tp6694p7382.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. >

Re: Spark Streaming not processing file with particular number of entries

2014-06-10 Thread praveshjain1991
Well i was able to get it to work by running spark over mesos. But it looks like a bug while running spark alone. -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-not-processing-file-with-particular-number-of-entries-tp6694p7382.html Sent

Re: Spark Streaming not processing file with particular number of entries

2014-06-05 Thread praveshjain1991
4945000 ms: 14/06/06 11:39:05 INFO JobScheduler: Added jobs for time 1402034945000 ms 14/06/06 11:39:06 INFO FileInputDStream: Finding new files took 1 ms 14/06/06 11:39:06 INFO FileInputDStream: New files at time 1402034946000 ms: 14/06/06 11:39:06 INFO JobScheduler: Added

Re: Spark Streaming not processing file with particular number of entries

2014-06-05 Thread praveshjain1991
The same issue persists in spark-1.0.0 as well (was using 0.9.1 earlier). Any suggestions are welcomed. -- Thanks -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-not-processing-file-with-particular-number-of-entries-tp6694p7056.html Sent

Spark Streaming not processing file with particular number of entries

2014-06-02 Thread praveshjain1991
fine. I've tried using different files that have that many number of entries but none of them work. Any ideas why such a wierd issue could occur? Thanks -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Spark-Streaming-not-processing-file-with-parti