Skip to content

Commit e9ad356

Browse files
committed
Update ContextCleanerSuite to make sure shuffle cleanup tests use hash
shuffle (since they were written for it)
1 parent c72362a commit e9ad356

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

core/src/test/scala/org/apache/spark/ContextCleanerSuite.scala

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -43,6 +43,7 @@ class ContextCleanerSuite extends FunSuite with BeforeAndAfter with LocalSparkCo
4343
.setMaster("local[2]")
4444
.setAppName("ContextCleanerSuite")
4545
.set("spark.cleaner.referenceTracking.blocking", "true")
46+
.set("spark.shuffle.manager", "org.apache.spark.shuffle.hash.HashShuffleManager")
4647

4748
before {
4849
sc = new SparkContext(conf)
@@ -180,6 +181,7 @@ class ContextCleanerSuite extends FunSuite with BeforeAndAfter with LocalSparkCo
180181
.setMaster("local-cluster[2, 1, 512]")
181182
.setAppName("ContextCleanerSuite")
182183
.set("spark.cleaner.referenceTracking.blocking", "true")
184+
.set("spark.shuffle.manager", "org.apache.spark.shuffle.hash.HashShuffleManager")
183185
sc = new SparkContext(conf2)
184186

185187
val numRdds = 10

0 commit comments

Comments
 (0)