Shutdown the thread scheduler in LoggingPodStatusWatcher on receiving job finish event notifications (apache-spark-on-k8s#121)

varunkatta · ash211 · commit 84315a6551f8 · 2017-02-16T23:31:00.000Z
diff --git a/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/LoggingPodStatusWatcher.scala b/resource-managers/kubernetes/core/src/main/scala/org/apache/spark/deploy/kubernetes/LoggingPodStatusWatcher.scala
@@ -64,6 +64,7 @@ private[kubernetes] class LoggingPodStatusWatcher(podCompletedFuture: CountDownL
 
     if (phase == "Succeeded" || phase == "Failed") {
       podCompletedFuture.countDown()
+      scheduler.shutdown()
     }
   }
 

Original file line number	Diff line number	Diff line change
`@@ -64,6 +64,7 @@ private[kubernetes] class LoggingPodStatusWatcher(podCompletedFuture: CountDownL`
`64`	`64`
`65`	`65`	`if (phase == "Succeeded" \|\| phase == "Failed") {`
`66`	`66`	`podCompletedFuture.countDown()`
	`67`	`+ scheduler.shutdown()`
`67`	`68`	`}`
`68`	`69`	`}`
`69`	`70`