Skip to content

Commit 47da0d7

Browse files
committed
fix
1 parent 404f92b commit 47da0d7

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

streaming/src/test/scala/org/apache/spark/streaming/scheduler/ExecutorAllocationManagerSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -98,7 +98,7 @@ class ExecutorAllocationManagerSuite extends TestSuiteBase
9898
/** Verify that a particular executor was scaled down. */
9999
def verifyScaledDownExec(expectedExec: Option[String]): Unit = {
100100
if (expectedExec.nonEmpty) {
101-
val decomInfo = ExecutorDecommissionInfo("spark scale down", false)
101+
val decomInfo = ExecutorDecommissionInfo("spark scale down", None)
102102
if (decommissioning) {
103103
verify(allocationClient, times(1)).decommissionExecutor(
104104
meq(expectedExec.get), meq(decomInfo), meq(true))

0 commit comments

Comments
 (0)