Github user ifilonenko commented on a diff in the pull request:
https://github.com/apache/spark/pull/19045#discussion_r229011769
--- Diff:
resource-managers/kubernetes/integration-tests/src/test/scala/org/apache/spark/deploy/k8s/integrationtest/KubernetesSuite.scala
---
@@ -242,12 +243,19 @@ private[spark] class KubernetesSuite extends
SparkFunSuite
action match {
case Action.ADDED | Action.MODIFIED =>
execPods(name) = resource
+ // If testing decomissioning delete the node 10 seconds after
+ if (decomissioningTest) {
+ Thread.sleep(1000)
--- End diff --
Why the thread sleep? Why not just check if the `getStatus` is running and
then kill?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
