diff options
author | Hossein Falaki <falaki@gmail.com> | 2013-12-10 19:50:50 -0800 |
---|---|---|
committer | Hossein Falaki <falaki@gmail.com> | 2013-12-10 19:50:50 -0800 |
commit | 49bf47e1b792b82561b164f4f8006ddd4dd350ee (patch) | |
tree | c7e15ec8ed1989c08ea8c20141718de895f8792b | |
parent | 2d511ab320a85eccafbb9e51a2183b07114bbaa1 (diff) | |
download | spark-49bf47e1b792b82561b164f4f8006ddd4dd350ee.tar.gz spark-49bf47e1b792b82561b164f4f8006ddd4dd350ee.tar.bz2 spark-49bf47e1b792b82561b164f4f8006ddd4dd350ee.zip |
Removed superfluous abs call from test cases.
-rw-r--r-- | core/src/test/scala/org/apache/spark/rdd/PairRDDFunctionsSuite.scala | 4 |
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) } } |