attilapiros commented on a change in pull request #33492:
URL: https://github.com/apache/spark/pull/33492#discussion_r675407048
##########
File path:
resource-managers/kubernetes/core/src/main/scala/org/apache/spark/scheduler/cluster/k8s/ExecutorPodsAllocator.scala
##########
@@ -235,7 +243,7 @@ private[spark] class ExecutorPodsAllocator(
}
// This variable is used later to print some debug logs. It's updated
when cleaning up
// excess pod requests, since currentPendingExecutorsForRpId is
immutable.
- var knownPendingCount = currentPendingExecutorsForRpId.size
+ var pendingCountForRpId = currentPendingExecutorsForRpId.size
Review comment:
This is a rename but the old name was misleading as it counts the
pending PODs which unknown by the scheduler.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
