Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/16650#discussion_r97878659
--- Diff:
core/src/test/scala/org/apache/spark/deploy/StandaloneDynamicAllocationSuite.scala
---
@@ -528,6 +548,16 @@ class StandaloneDynamicAllocationSuite
}
}
+ /** Kill the executors on a given host. */
+ private def killExecutorsOnHost(sc: SparkContext, host: String): Boolean
= {
+ syncExecutors(sc)
+ sc.schedulerBackend match {
+ case b: CoarseGrainedSchedulerBackend =>
+ b.killExecutorsOnHost(host, false)
--- End diff --
is this test the only reason to expose the `replace` argument? if so, I
think you could change the test to just check for new executors.
`apps.head.executors.keys.toSet` to get the executors. (you may need to use
`keys.toSet`, instead of `.keySet`, because `.keySet` will just be a view which
is not static.)
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
