You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2014/02/05 21:44:27 UTC
git commit: Merge pull request #544 from
kayousterhout/fix_test_warnings. Closes #544.
Updated Branches:
refs/heads/master f7fd80d9a -> cc14ba974
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 <ka...@gmail.com>
== Merge branch commits ==
commit da9d2e13ee4102bc58888df0559c65cb26232a82
Author: Kay Ousterhout <ka...@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.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/cc14ba97
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/cc14ba97
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/cc14ba97
Branch: refs/heads/master
Commit: cc14ba974c8e98c08548a2ccf64c2765f313f649
Parents: f7fd80d
Author: Kay Ousterhout <ka...@gmail.com>
Authored: Wed Feb 5 12:44:24 2014 -0800
Committer: Reynold Xin <rx...@apache.org>
Committed: Wed Feb 5 12:44:24 2014 -0800
----------------------------------------------------------------------
.../test/scala/org/apache/spark/api/python/PythonRDDSuite.scala | 1 -
core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala | 2 +-
2 files changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/cc14ba97/core/src/test/scala/org/apache/spark/api/python/PythonRDDSuite.scala
----------------------------------------------------------------------
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 1bebfe5..5bcebab 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}
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/cc14ba97/core/src/test/scala/org/apache/spark/rdd/RDDSuite.scala
----------------------------------------------------------------------
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 cd01303..223ebec 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)))