Handful of changes based on matei's review

- Avoid exception when no tasks have finished for a stage
- Adding DOCTYPE so css renders properly
- Adding progress slider

1 files changed, 5 insertions, 1 deletions

diff --git a/streaming/src/main/scala/spark/streaming/Duration.scala b/streaming/src/main/scala/spark/streaming/Duration.scala
index ee26206e24..c2135195d8 100644
--- a/streaming/src/main/scala/spark/streaming/Duration.scala
+++ b/streaming/src/main/scala/spark/streaming/Duration.scala
@@ -1,5 +1,7 @@
 package spark.streaming
 
+import spark.Utils
+
 case class Duration (private val millis: Long) {
 
   def < (that: Duration): Boolean = (this.millis < that.millis)
@@ -32,8 +34,10 @@ case class Duration (private val millis: Long) {
   def toFormattedString: String = millis.toString
 
   def milliseconds: Long = millis
-}
 
+  def prettyPrint = Utils.msDurationToString(millis)
+
+}
 
 /**
  * Helper object that creates instance of [[spark.streaming.Duration]] representing