Make log message more descriptive to aid in debugging

1 files changed, 3 insertions, 1 deletions

diff --git a/streaming/src/main/scala/spark/streaming/Checkpoint.scala b/streaming/src/main/scala/spark/streaming/Checkpoint.scala
index 4bbad908d0..66e67cbfa1 100644
--- a/streaming/src/main/scala/spark/streaming/Checkpoint.scala
+++ b/streaming/src/main/scala/spark/streaming/Checkpoint.scala
@@ -100,8 +100,10 @@ class CheckpointWriter(checkpointDir: String) extends Logging {
       stopped = true
     }
     executor.shutdown()
+    val startTime = System.currentTimeMillis()
     val terminated = executor.awaitTermination(10, java.util.concurrent.TimeUnit.SECONDS)
-    logInfo("CheckpointWriter executor terminated ? " + terminated)
+    val endTime = System.currentTimeMillis()
+    logInfo("CheckpointWriter executor terminated ? " + terminated + ", waited for " + (endTime - startTime) + " ms.")
   }
 }