aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2012-10-01 10:57:26 -0700
committerMatei Zaharia <matei@eecs.berkeley.edu>2012-10-01 10:57:26 -0700
commit0b84871dbca8a1a33407e7322e3c6162d24b4c29 (patch)
tree4123edae06900e676ac2e2fc131d2bd31f9bf96c
parent53f90d0f0ea8ae605e95ece9850df6004123c787 (diff)
downloadspark-0b84871dbca8a1a33407e7322e3c6162d24b4c29.tar.gz
spark-0b84871dbca8a1a33407e7322e3c6162d24b4c29.tar.bz2
spark-0b84871dbca8a1a33407e7322e3c6162d24b4c29.zip
Remove some printlns in tests
-rw-r--r--core/src/test/scala/spark/JavaAPISuite.java6
-rw-r--r--core/src/test/scala/spark/PipedRDDSuite.scala1
2 files changed, 5 insertions, 2 deletions
diff --git a/core/src/test/scala/spark/JavaAPISuite.java b/core/src/test/scala/spark/JavaAPISuite.java
index 24bf021710..5875506179 100644
--- a/core/src/test/scala/spark/JavaAPISuite.java
+++ b/core/src/test/scala/spark/JavaAPISuite.java
@@ -112,15 +112,19 @@ public class JavaAPISuite implements Serializable {
Assert.assertEquals(new Tuple2<Integer, Integer>(3, 2), sortedPairs.get(2));
}
+ static int foreachCalls = 0;
+
@Test
public void foreach() {
+ foreachCalls = 0;
JavaRDD<String> rdd = sc.parallelize(Arrays.asList("Hello", "World"));
rdd.foreach(new VoidFunction<String>() {
@Override
public void call(String s) {
- System.out.println(s);
+ foreachCalls++;
}
});
+ Assert.assertEquals(2, foreachCalls);
}
@Test
diff --git a/core/src/test/scala/spark/PipedRDDSuite.scala b/core/src/test/scala/spark/PipedRDDSuite.scala
index 426652dc15..add5221e30 100644
--- a/core/src/test/scala/spark/PipedRDDSuite.scala
+++ b/core/src/test/scala/spark/PipedRDDSuite.scala
@@ -22,7 +22,6 @@ class PipedRDDSuite extends FunSuite with BeforeAndAfter {
val piped = nums.pipe(Seq("cat"))
val c = piped.collect()
- println(c.toSeq)
assert(c.size === 4)
assert(c(0) === "1")
assert(c(1) === "2")