Try doing DStream.foreachRDD and then printing the RDD count and further inspecting the RDD. On Jul 13, 2014 1:03 AM, "Walrus theCat" <walrusthe...@gmail.com> wrote:
> Hi, > > I have a DStream that works just fine when I say: > > dstream.print > > If I say: > > dstream.map(_,1).print > > that works, too. However, if I do the following: > > dstream.reduce{case(x,y) => x}.print > > I don't get anything on my console. What's going on? > > Thanks >