Skip to content
Snippets Groups Projects
Commit fac53d8e authored by Josh Rosen's avatar Josh Rosen
Browse files

[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.
parent 6e101d2e
No related branches found
No related tags found
No related merge requests found
...@@ -1070,7 +1070,7 @@ class DAGSchedulerSuite ...@@ -1070,7 +1070,7 @@ class DAGSchedulerSuite
// Run the first job successfully, which creates one shuffle dependency // Run the first job successfully, which creates one shuffle dependency
val shuffleMapRdd = new MyRDD(sc, 2, Nil) 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)) val reduceRdd = new MyRDD(sc, 2, List(shuffleDep))
submit(reduceRdd, Array(0, 1)) submit(reduceRdd, Array(0, 1))
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment