You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by jo...@apache.org on 2015/11/11 07:24:10 UTC
spark git commit: [SPARK-10192][HOTFIX] Fix NPE in test that was
added in #8402
Repository: spark
Updated Branches:
refs/heads/master 6e101d2e9 -> fac53d8ec
[SPARK-10192][HOTFIX] Fix NPE in test that was added in #8402
This fixes an NPE introduced in SPARK-10192 / #8402.
Author: Josh Rosen <jo...@databricks.com>
Closes #9620 from JoshRosen/SPARK-10192-hotfix.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/fac53d8e
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/fac53d8e
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/fac53d8e
Branch: refs/heads/master
Commit: fac53d8ec015e27d034dfe30ed8ce7d83f07efa6
Parents: 6e101d2
Author: Josh Rosen <jo...@databricks.com>
Authored: Tue Nov 10 22:24:00 2015 -0800
Committer: Josh Rosen <jo...@databricks.com>
Committed: Tue Nov 10 22:24:00 2015 -0800
----------------------------------------------------------------------
.../test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/fac53d8e/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
index 068b49b..4d6b254 100644
--- a/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
+++ b/core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala
@@ -1070,7 +1070,7 @@ class DAGSchedulerSuite
// Run the first job successfully, which creates one shuffle dependency
val shuffleMapRdd = new MyRDD(sc, 2, Nil)
- val shuffleDep = new ShuffleDependency(shuffleMapRdd, null)
+ val shuffleDep = new ShuffleDependency(shuffleMapRdd, new HashPartitioner(2))
val reduceRdd = new MyRDD(sc, 2, List(shuffleDep))
submit(reduceRdd, Array(0, 1))
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org