diff options
| author | Josh Rosen <joshrosen@databricks.com> | 2015-11-10 22:24:00 -0800 |
|---|---|---|
| committer | Josh Rosen <joshrosen@databricks.com> | 2015-11-10 22:24:00 -0800 |
| commit | fac53d8ec015e27d034dfe30ed8ce7d83f07efa6 (patch) | |
| tree | b2fa6c9ba9ae87be1a7ca2d695d223c90fb5eea9 /core | |
| parent | 6e101d2e9d6e08a6a63f7065c1e87a5338f763ea (diff) | |
| download | spark-fac53d8ec015e27d034dfe30ed8ce7d83f07efa6.tar.gz spark-fac53d8ec015e27d034dfe30ed8ce7d83f07efa6.tar.bz2 spark-fac53d8ec015e27d034dfe30ed8ce7d83f07efa6.zip | |
[SPARK-10192][HOTFIX] Fix NPE in test that was added in #8402
This fixes an NPE introduced in SPARK-10192 / #8402.
Author: Josh Rosen <joshrosen@databricks.com>
Closes #9620 from JoshRosen/SPARK-10192-hotfix.
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/test/scala/org/apache/spark/scheduler/DAGSchedulerSuite.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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)) |