We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 17a6a3f commit 155aeb2Copy full SHA for 155aeb2
1 file changed
core/src/test/scala/org/apache/spark/storage/BlockManagerDecommissionSuite.scala
@@ -130,15 +130,15 @@ class BlockManagerDecommissionSuite extends SparkFunSuite with LocalSparkContext
130
// Wait for the first executor to start
131
TestUtils.waitUntilExecutorsUp(sc = sc,
132
numExecutors = 1,
133
- timeout = 10000) // 10s
+ timeout = 20000) // 20s
134
135
// Start the computation of RDD - this step will also cache the RDD
136
val asyncCount = testRdd.countAsync()
137
138
// Wait for all of the executors to start
139
140
numExecutors = numExecs,
141
+ timeout = 30000) // 30s
142
143
// Wait for the job to have started.
144
taskStartSem.acquire(1)
0 commit comments