Skip to content

Conversation

@zsxwing
Copy link
Member

@zsxwing zsxwing commented Jun 4, 2015

This PR includes the following changes:

  • Add StreamingListenerBlockAdded and StreamingListenerBlockRemoved events for StreamingListener to track the block statuses.
  • Add StreamingUI to support more than one tabs in the Streaming UI.
  • Add Streaming Storage tab to display blocks used by Streaming.

screen shot 2015-06-04 at 3 40 43 pm

@zsxwing
Copy link
Member Author

zsxwing commented Jun 4, 2015

@tdas could you take a look please?

@tdas
Copy link
Contributor

tdas commented Jun 4, 2015

Aaaah, this is an interesting approach. However, I am wondering if this is the best approach. I was thinking that maybe the existing Storage tab should show blocks along with RDDs. That may be more consistent, with one tab having all the information.

@pwendell What do you think about a design for this.

@SparkQA
Copy link

SparkQA commented Jun 4, 2015

Test build #34164 has finished for PR 6634 at commit c6ff8a9.

  • This patch passes all tests.
  • This patch merges cleanly.
  • This patch adds the following public classes (experimental):
    • case class StreamingListenerBlockAdded(blockInfo: ReceivedBlockInfo)
    • case class StreamingListenerBlockRemoved(blockIds: Seq[BlockId])
    • case class StreamBlockUIData(
    • class StreamingUI(val ssc: StreamingContext)

@zsxwing zsxwing closed this Jun 5, 2015
asfgit pushed a commit that referenced this pull request Jul 14, 2015
Replace #6634

This PR adds `SparkListenerBlockUpdated` to SparkListener so that it can monitor all block update infos that are sent to `BlockManagerMasaterEndpoint`, and also add new tables in the Storage tab to display the stream block infos.

![screen shot 2015-07-01 at 5 19 46 pm](https://cloud.githubusercontent.com/assets/1000778/8451562/c291a6ec-2016-11e5-890d-0afc174e1f8c.png)

Author: zsxwing <zsxwing@gmail.com>

Closes #6672 from zsxwing/SPARK-4072-2 and squashes the following commits:

df2c1d8 [zsxwing] Use xml query to check the xml elements
54d54af [zsxwing] Add unit tests for StoragePage
e29fb53 [zsxwing] Update as per TD's comments
ccbee07 [zsxwing] Fix the code style
6dc42b4 [zsxwing] Fix the replication level of blocks
450fad1 [zsxwing] Merge branch 'master' into SPARK-4072-2
1e9ef52 [zsxwing] Don't categorize by Executor ID
ca0ab69 [zsxwing] Fix the code style
3de2762 [zsxwing] Make object BlockUpdatedInfo private
e95b594 [zsxwing] Add 'Aggregated Stream Block Metrics by Executor' table
ba5d0d1 [zsxwing] Refactor the unit test to improve the readability
4bbe341 [zsxwing] Revert JsonProtocol and don't log SparkListenerBlockUpdated
b464dd1 [zsxwing] Add onBlockUpdated to EventLoggingListener
5ba014c [zsxwing] Fix the code style
0b1e47b [zsxwing] Add a developer api BlockUpdatedInfo
04838a9 [zsxwing] Fix the code style
2baa161 [zsxwing] Add unit tests
80f6c6d [zsxwing] Address comments
797ee4b [zsxwing] Display Streaming blocks in Streaming UI
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants