I have tried some workload that only the first partition will be computed because the first partition suffice to provide the ten rows.
In your case, you have called saveAsTextFiles, all partitions should be computed. So I don't know the root cause yet. I just wanna remind you that some workloads seem to be toy workloads that call DStream.print() at the end. On Sun, Feb 2, 2014 at 10:18 AM, OlegYch <[email protected]> wrote: > Do you mean the popularUsersSeen metric? Because otherwise all the other > streams are supposed to operate on the whole stream, as far as i can see. > > > > -- > View this message in context: > http://apache-spark-user-list.1001560.n3.nabble.com/PageView-streaming-sample-lost-page-views-tp1126p1128.html > Sent from the Apache Spark User List mailing list archive at Nabble.com. > -- Dachuan Huang Cellphone: 614-390-7234 2015 Neil Avenue Ohio State University Columbus, Ohio U.S.A. 43210
