diff options
| author | Kay Ousterhout <kayousterhout@gmail.com> | 2014-02-05 12:44:24 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-02-05 12:44:24 -0800 |
| commit | cc14ba974c8e98c08548a2ccf64c2765f313f649 (patch) | |
| tree | 868a5fbe43dea41bf5f60f493d9e94013f963a3e /core | |
| parent | f7fd80d9a71069cba94294e6b77c0eaeb90e73d7 (diff) | |
| download | spark-cc14ba974c8e98c08548a2ccf64c2765f313f649.tar.gz spark-cc14ba974c8e98c08548a2ccf64c2765f313f649.tar.bz2 spark-cc14ba974c8e98c08548a2ccf64c2765f313f649.zip | |
Merge pull request #544 from kayousterhout/fix_test_warnings. Closes #544.
Fixed warnings in test compilation.
This commit fixes two problems: a redundant import, and a
deprecated function.
Author: Kay Ousterhout <kayousterhout@gmail.com>
== Merge branch commits ==
commit da9d2e13ee4102bc58888df0559c65cb26232a82
Author: Kay Ousterhout <kayousterhout@gmail.com>
Date: Wed Feb 5 11:41:51 2014 -0800
Fixed warnings in test compilation.
This commit fixes two problems: a redundant import, and a
deprecated function.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/test/scala/org/apache/spark/api/python/PythonRDDSuite.scala | 1 | ||||
| -rw-r--r-- | core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala | 2 |
2 files changed, 1 insertions, 2 deletions
diff --git a/core/src/test/scala/org/apache/spark/api/python/PythonRDDSuite.scala b/core/src/test/scala/org/apache/spark/api/python/PythonRDDSuite.scala index 1bebfe5ec8..5bcebabc9a 100644 --- a/core/src/test/scala/org/apache/spark/api/python/PythonRDDSuite.scala +++ b/core/src/test/scala/org/apache/spark/api/python/PythonRDDSuite.scala @@ -19,7 +19,6 @@ package org.apache.spark.api.python import org.scalatest.FunSuite import org.scalatest.matchers.ShouldMatchers -import org.apache.spark.api.python.PythonRDD import java.io.{ByteArrayOutputStream, DataOutputStream} diff --git a/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala b/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala index cd01303bad..223ebec5fa 100644 --- a/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala +++ b/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala @@ -48,7 +48,7 @@ class RDDSuite extends FunSuite with SharedSparkContext { val partitionSums = nums.mapPartitions(iter => Iterator(iter.reduceLeft(_ + _))) assert(partitionSums.collect().toList === List(3, 7)) - val partitionSumsWithSplit = nums.mapPartitionsWithSplit { + val partitionSumsWithSplit = nums.mapPartitionsWithIndex { case(split, iter) => Iterator((split, iter.reduceLeft(_ + _))) } assert(partitionSumsWithSplit.collect().toList === List((0, 3), (1, 7))) |