-
- Downloads
[SPARK-11333][STREAMING] Add executorId to ReceiverInfo and display it in UI
Expose executorId to `ReceiverInfo` and UI since it's helpful when there are multiple executors running in the same host. Screenshot: <img width="1058" alt="screen shot 2015-11-02 at 10 52 19 am" src="https://cloud.githubusercontent.com/assets/1000778/10890968/2e2f5512-8150-11e5-8d9d-746e826b69e8.png"> Author: Shixiong Zhu <shixiong@databricks.com> Author: zsxwing <zsxwing@gmail.com> Closes #9418 from zsxwing/SPARK-11333.
Showing
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingListener.scala 1 addition, 0 deletions...ache/spark/streaming/api/java/JavaStreamingListener.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingListenerWrapper.scala 1 addition, 0 deletions...ark/streaming/api/java/JavaStreamingListenerWrapper.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverInfo.scala 1 addition, 0 deletions...a/org/apache/spark/streaming/scheduler/ReceiverInfo.scala
- streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceiverTrackingInfo.scala 1 addition, 0 deletions...ache/spark/streaming/scheduler/ReceiverTrackingInfo.scala
- streaming/src/main/scala/org/apache/spark/streaming/ui/StreamingPage.scala 6 additions, 2 deletions...n/scala/org/apache/spark/streaming/ui/StreamingPage.scala
- streaming/src/test/java/org/apache/spark/streaming/JavaStreamingListenerAPISuite.java 3 additions, 0 deletions...apache/spark/streaming/JavaStreamingListenerAPISuite.java
- streaming/src/test/java/org/apache/spark/streaming/api/java/JavaStreamingListenerWrapperSuite.scala 6 additions, 2 deletions...treaming/api/java/JavaStreamingListenerWrapperSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/ui/StreamingJobProgressListenerSuite.scala 3 additions, 3 deletions...park/streaming/ui/StreamingJobProgressListenerSuite.scala
Loading
Please register or sign in to comment