From fac53d8ec015e27d034dfe30ed8ce7d83f07efa6 Mon Sep 17 00:00:00 2001 From: Josh Rosen Date: Tue, 10 Nov 2015 22:24:00 -0800 Subject: [SPARK-10192][HOTFIX] Fix NPE in test that was added in #8402 This fixes an NPE introduced in SPARK-10192 / #8402. Author: Josh Rosen Closes #9620 from JoshRosen/SPARK-10192-hotfix. --- core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'core') 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 068b49bd58..4d6b254552 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)) -- cgit v1.2.3