aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorHossein Falaki <falaki@gmail.com>2013-12-10 19:50:50 -0800
committerHossein Falaki <falaki@gmail.com>2013-12-10 19:50:50 -0800
commit49bf47e1b792b82561b164f4f8006ddd4dd350ee (patch)
treec7e15ec8ed1989c08ea8c20141718de895f8792b /core
parent2d511ab320a85eccafbb9e51a2183b07114bbaa1 (diff)
downloadspark-49bf47e1b792b82561b164f4f8006ddd4dd350ee.tar.gz
spark-49bf47e1b792b82561b164f4f8006ddd4dd350ee.tar.bz2
spark-49bf47e1b792b82561b164f4f8006ddd4dd350ee.zip
Removed superfluous abs call from test cases.
Diffstat (limited to 'core')
-rw-r--r--core/src/test/scala/org/apache/spark/rdd/PairRDDFunctionsSuite.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/test/scala/org/apache/spark/rdd/PairRDDFunctionsSuite.scala b/core/src/test/scala/org/apache/spark/rdd/PairRDDFunctionsSuite.scala
index 5683ada78a..6ad58b875d 100644
--- a/core/src/test/scala/org/apache/spark/rdd/PairRDDFunctionsSuite.scala
+++ b/core/src/test/scala/org/apache/spark/rdd/PairRDDFunctionsSuite.scala
@@ -126,7 +126,7 @@ class PairRDDFunctionsSuite extends FunSuite with SharedSparkContext {
val rdd1 = sc.parallelize(stacked)
val counted1 = rdd1.countDistinctByKey(relativeSD).collect()
counted1.foreach{
- case(k, count) => assert(math.abs(error(count, k)) < relativeSD)
+ case(k, count) => assert(error(count, k) < relativeSD)
}
val rnd = new Random()
@@ -139,7 +139,7 @@ class PairRDDFunctionsSuite extends FunSuite with SharedSparkContext {
val rdd2 = sc.parallelize(randStacked)
val counted2 = rdd2.countDistinctByKey(relativeSD, 4).collect()
counted2.foreach{
- case(k, count) => assert(math.abs(error(count, k)) < relativeSD)
+ case(k, count) => assert(error(count, k) < relativeSD)
}
}