hi Diego, I have the same problem.
// reduce by key in the first window val *w1* = *one*.reduceByKeyAndWindow(_ + _, Seconds(30), Seconds(10)) w1.count().print() //reduce by key in the second window based on the results of the first window val *w2* = *w1*.reduceByKeyAndWindow(_ + _, Seconds(120), Seconds(30)) w2.print() then w1 works, but w2 always does not print any information. Do you have any update for this issue? -- View this message in context: http://apache-spark-user-list.1001560.n3.nabble.com/Windowed-Operations-tp15133p16128.html Sent from the Apache Spark User List mailing list archive at Nabble.com. --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
