Skip to content

Commit 404f92b

Browse files
committed
fix compile error
1 parent d5bc756 commit 404f92b

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

streaming/src/main/scala/org/apache/spark/streaming/scheduler/ExecutorAllocationManager.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,7 @@ private[streaming] class ExecutorAllocationManager(
137137
val execIdToRemove = removableExecIds(Random.nextInt(removableExecIds.size))
138138
if (conf.get(DECOMMISSION_ENABLED)) {
139139
client.decommissionExecutor(execIdToRemove,
140-
ExecutorDecommissionInfo("spark scale down", false),
140+
ExecutorDecommissionInfo("spark scale down", None),
141141
adjustTargetNumExecutors = true)
142142
} else {
143143
client.killExecutor(execIdToRemove)

0 commit comments

Comments
 (0)