From 3a89a76b874298853cf47510ab33e863abf117d7 Mon Sep 17 00:00:00 2001
From: Mridul Muralidharan <mridul@gmail.com>
Date: Mon, 29 Apr 2013 00:04:12 +0530
Subject: [PATCH] Make log message more descriptive to aid in debugging
---
streaming/src/main/scala/spark/streaming/Checkpoint.scala | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
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.")
}
}
--
GitLab