Searched refs:shuffleDep1 (Results 1 – 1 of 1) sorted by relevance
| /dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/scheduler/ |
| H A D | DAGSchedulerSuite.scala | 1437 val shuffleDep1 = new ShuffleDependency(shuffleMapRdd1, new HashPartitioner(2)) constant
1441 val reduceRdd1 = new MyRDD(sc, 2, List(shuffleDep1), tracker = mapOutputTracker)
1442 val reduceRdd2 = new MyRDD(sc, 2, List(shuffleDep1, shuffleDep2), tracker = mapOutputTracker)
1480 val shuffleDep1 = new ShuffleDependency(baseRdd, new HashPartitioner(1)) constant
1481 val intermediateRdd = new MyRDD(sc, 1, List(shuffleDep1))
1515 shuffleDep1
1546 val shuffleDep1 = launchJobsThatShareStageAndCancelFirst() constant
1552 (FetchFailed(makeBlockManagerId("hostA"), shuffleDep1.shuffleId, 0, 0, "ignored"), null)))
|