Skip to content
This repository was archived by the owner on Jan 9, 2020. It is now read-only.

Commit dc4e3d2

Browse files
committed
Logging for resource deletion (#170)
* Logging for resource deletion Remove dangling colon and replace with an ellipses and a second log statement * Update KubernetesResourceCleaner.scala
1 parent 191dd51 commit dc4e3d2

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/KubernetesResourceCleaner.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,13 +39,15 @@ private[spark] class KubernetesResourceCleaner extends Logging {
3939

4040
def deleteAllRegisteredResourcesFromKubernetes(kubernetesClient: KubernetesClient): Unit = {
4141
synchronized {
42-
logInfo(s"Deleting ${resources.size} registered Kubernetes resources:")
42+
val resourceCount = resources.size
43+
logInfo(s"Deleting ${resourceCount} registered Kubernetes resources...")
4344
resources.values.foreach { resource =>
4445
Utils.tryLogNonFatalError {
4546
kubernetesClient.resource(resource).delete()
4647
}
4748
}
4849
resources.clear()
50+
logInfo(s"Deleted ${resourceCount} registered Kubernetes resources.")
4951
}
5052
}
5153
}

0 commit comments

Comments
 (0)