diff --git a/core/src/test/scala/org/apache/spark/executor/CoarseGrainedExecutorBackendSuite.scala b/core/src/test/scala/org/apache/spark/executor/CoarseGrainedExecutorBackendSuite.scala index 7bd84c810c42e..8b98df103c014 100644 --- a/core/src/test/scala/org/apache/spark/executor/CoarseGrainedExecutorBackendSuite.scala +++ b/core/src/test/scala/org/apache/spark/executor/CoarseGrainedExecutorBackendSuite.scala @@ -37,7 +37,7 @@ import org.scalatestplus.mockito.MockitoSugar import org.apache.spark._ import org.apache.spark.TestUtils._ import org.apache.spark.api.plugin.{DriverPlugin, ExecutorPlugin, PluginContext, SparkPlugin} -import org.apache.spark.internal.config.PLUGINS +import org.apache.spark.internal.config.{EXECUTOR_MEMORY, PLUGINS} import org.apache.spark.resource._ import org.apache.spark.resource.ResourceUtils._ import org.apache.spark.resource.TestResourceIDs._ @@ -581,7 +581,8 @@ class CoarseGrainedExecutorBackendSuite extends SparkFunSuite */ test("SPARK-40320 Executor should exit when initialization failed for fatal error") { val conf = createSparkConf() - .setMaster("local-cluster[1, 1, 1024]") + .setMaster("local-cluster[1, 1, 512]") + .set(EXECUTOR_MEMORY.key, "512m") .set(PLUGINS, Seq(classOf[TestFatalErrorPlugin].getName)) .setAppName("test") sc = new SparkContext(conf) @@ -599,7 +600,7 @@ class CoarseGrainedExecutorBackendSuite extends SparkFunSuite } try { sc.addSparkListener(listener) - eventually(timeout(15.seconds)) { + eventually(timeout(30.seconds)) { assert(executorAddCounter.get() >= 2) assert(executorRemovedCounter.get() >= 2) }