We only need two executors for this test.

holdenk · holdenk · commit adb03dbf44f1 · 2020-05-01T16:16:08.000-07:00
diff --git a/core/src/test/scala/org/apache/spark/storage/BlockManagerDecommissionSuite.scala b/core/src/test/scala/org/apache/spark/storage/BlockManagerDecommissionSuite.scala
@@ -36,7 +36,7 @@ class BlockManagerDecommissionSuite extends SparkFunSuite with LocalSparkContext
       .set(config.STORAGE_DECOMMISSION_REPLICATION_REATTEMPT_INTERVAL, 100L)
       .set(config.STORAGE_DECOMMISSION_ENABLED, true)
 
-    sc = new SparkContext("local-cluster[3, 1, 1024]", "test", conf)
+    sc = new SparkContext("local-cluster[2, 1, 1024]", "test", conf)
   }
 
   test(s"verify that an already running task which is going to cache data succeeds " +

Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ class BlockManagerDecommissionSuite extends SparkFunSuite with LocalSparkContext`
`36`	`36`	`.set(config.STORAGE_DECOMMISSION_REPLICATION_REATTEMPT_INTERVAL, 100L)`
`37`	`37`	`.set(config.STORAGE_DECOMMISSION_ENABLED, true)`
`38`	`38`
`39`		`- sc = new SparkContext("local-cluster[3, 1, 1024]", "test", conf)`
	`39`	`+ sc = new SparkContext("local-cluster[2, 1, 1024]", "test", conf)`
`40`	`40`	`}`
`41`	`41`
`42`	`42`	`test(s"verify that an already running task which is going to cache data succeeds " +`