From 780de029948fb5371ecfc6fc3c91497ebbfb6dd5 Mon Sep 17 00:00:00 2001 From: mcheah Date: Fri, 3 Mar 2017 15:18:45 -0800 Subject: [PATCH] Propagate exceptions --- .../main/scala/org/apache/spark/deploy/kubernetes/Client.scala | 1 + 1 file changed, 1 insertion(+) diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala index d38d84f7b3ed3..770821e97d12c 100644 --- a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala +++ b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/Client.scala @@ -201,6 +201,7 @@ private[spark] class Client( } catch { case e: Throwable => driverServiceManager.handleSubmissionError(e) + throw e } finally { Utils.tryLogNonFatalError { kubernetesResourceCleaner.deleteAllRegisteredResourcesFromKubernetes(kubernetesClient)