diff options
author | Mridul Muralidharan <mridul@gmail.com> | 2013-04-29 00:04:12 +0530 |
---|---|---|
committer | Mridul Muralidharan <mridul@gmail.com> | 2013-04-29 00:04:12 +0530 |
commit | 3a89a76b874298853cf47510ab33e863abf117d7 (patch) | |
tree | 1b4a8dca989b7d9b319eff1f23f30fab93d0fcd6 | |
parent | 9bd439502e371e1ff9d6184c7182bc414104e39e (diff) | |
download | spark-3a89a76b874298853cf47510ab33e863abf117d7.tar.gz spark-3a89a76b874298853cf47510ab33e863abf117d7.tar.bz2 spark-3a89a76b874298853cf47510ab33e863abf117d7.zip |
Make log message more descriptive to aid in debugging
-rw-r--r-- | streaming/src/main/scala/spark/streaming/Checkpoint.scala | 4 |
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.") } } |