0
@@ -57,7 +57,7 @@ object defaults {
0
     } else {
0
       val sz = x.size / numShards.n;
0
       val arrs = new ArrayBuffer[Iterable[T]]
0
-      arrs ++= (for(val i <- 0 until numShards.n ) yield x.drop(sz * i).take(sz));
0
+      arrs ++= (for(val i <- 0 until numShards.n ) yield x.drop(sz * i).take(sz).toList);
0
       arrs.toList
0
     }
0
     case _ =>

0
@@ -297,6 +297,6 @@ private[smr] object InternalIterable {
0
 
0
   private def handleReduce[T,B>:T](self : InternalIterable[T], f : (B,B)=>B) =  {
0
     val b = handleGather[T,Iterable[T],Option[B]](self,(x : Iterable[B])=> if (x.isEmpty) None else Some(x.reduceLeft(f)))
0
-    b.filter(None!=).map( (x : (Int,Option[B])) => x._2.get).reduceLeft(f);
0
+    b.filter(None!=).map{ (x : (Int,Option[B])) => println(x._1); x._2.get}.reduceLeft(f);
0
   }
0
 }