-
- Downloads
[SPARK-10974] [STREAMING] Add progress bar for output operation column and use...
[SPARK-10974] [STREAMING] Add progress bar for output operation column and use red dots for failed batches Screenshot: <img width="1363" alt="1" src="https://cloud.githubusercontent.com/assets/1000778/10342571/385d9340-6d4c-11e5-8e79-1fa4c3c98f81.png"> Also fixed the description and duration for output operations that don't have spark jobs. <img width="1354" alt="2" src="https://cloud.githubusercontent.com/assets/1000778/10342775/4bd52a0e-6d4d-11e5-99bc-26265a9fc792.png"> Author: zsxwing <zsxwing@gmail.com> Closes #9010 from zsxwing/output-op-progress-bar.
Showing
- streaming/src/main/resources/org/apache/spark/streaming/ui/static/streaming-page.js 16 additions, 10 deletions...es/org/apache/spark/streaming/ui/static/streaming-page.js
- streaming/src/main/scala/org/apache/spark/streaming/DStreamGraph.scala 1 addition, 1 deletion.../main/scala/org/apache/spark/streaming/DStreamGraph.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/BatchInfo.scala 3 additions, 20 deletions...cala/org/apache/spark/streaming/scheduler/BatchInfo.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/Job.scala 26 additions, 4 deletions...main/scala/org/apache/spark/streaming/scheduler/Job.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobScheduler.scala 6 additions, 6 deletions...a/org/apache/spark/streaming/scheduler/JobScheduler.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/JobSet.scala 3 additions, 14 deletions...n/scala/org/apache/spark/streaming/scheduler/JobSet.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/OutputOperationInfo.scala 5 additions, 1 deletion...pache/spark/streaming/scheduler/OutputOperationInfo.scala
- streaming/src/main/scala/org/apache/spark/streaming/ui/AllBatchesTable.scala 24 additions, 16 deletions...scala/org/apache/spark/streaming/ui/AllBatchesTable.scala
- streaming/src/main/scala/org/apache/spark/streaming/ui/BatchPage.scala 70 additions, 104 deletions.../main/scala/org/apache/spark/streaming/ui/BatchPage.scala
- streaming/src/main/scala/org/apache/spark/streaming/ui/BatchUIData.scala 62 additions, 5 deletions...ain/scala/org/apache/spark/streaming/ui/BatchUIData.scala
- streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingJobProgressListener.scala 14 additions, 0 deletions...che/spark/streaming/ui/StreamingJobProgressListener.scala
- streaming/src/test/scala/org/apache/spark/streaming/StreamingListenerSuite.scala 9 additions, 7 deletions...a/org/apache/spark/streaming/StreamingListenerSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/UISeleniumSuite.scala 1 addition, 1 deletion...st/scala/org/apache/spark/streaming/UISeleniumSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/ui/StreamingJobProgressListenerSuite.scala 18 additions, 12 deletions...park/streaming/ui/StreamingJobProgressListenerSuite.scala
Loading
Please register or sign in to comment