-
- Downloads
SPARK-2565. Update ShuffleReadMetrics as blocks are fetched
Author: Sandy Ryza <sandy@cloudera.com> Closes #1507 from sryza/sandy-spark-2565 and squashes the following commits: 74dad41 [Sandy Ryza] SPARK-2565. Update ShuffleReadMetrics as blocks are fetched
Showing
- core/src/main/scala/org/apache/spark/executor/Executor.scala 1 addition, 0 deletionscore/src/main/scala/org/apache/spark/executor/Executor.scala
- core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala 42 additions, 13 deletions...rc/main/scala/org/apache/spark/executor/TaskMetrics.scala
- core/src/main/scala/org/apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala 4 additions, 9 deletions.../apache/spark/shuffle/hash/BlockStoreShuffleFetcher.scala
- core/src/main/scala/org/apache/spark/shuffle/hash/HashShuffleReader.scala 3 additions, 1 deletion...ala/org/apache/spark/shuffle/hash/HashShuffleReader.scala
- core/src/main/scala/org/apache/spark/storage/BlockFetcherIterator.scala 15 additions, 25 deletions...scala/org/apache/spark/storage/BlockFetcherIterator.scala
- core/src/main/scala/org/apache/spark/storage/BlockManager.scala 7 additions, 4 deletions...rc/main/scala/org/apache/spark/storage/BlockManager.scala
- core/src/main/scala/org/apache/spark/util/JsonProtocol.scala 2 additions, 3 deletionscore/src/main/scala/org/apache/spark/util/JsonProtocol.scala
- core/src/test/scala/org/apache/spark/storage/BlockFetcherIteratorSuite.scala 7 additions, 6 deletions.../org/apache/spark/storage/BlockFetcherIteratorSuite.scala
- core/src/test/scala/org/apache/spark/ui/jobs/JobProgressListenerSuite.scala 2 additions, 2 deletions...a/org/apache/spark/ui/jobs/JobProgressListenerSuite.scala
- core/src/test/scala/org/apache/spark/util/JsonProtocolSuite.scala 1 addition, 1 deletion.../test/scala/org/apache/spark/util/JsonProtocolSuite.scala
Loading
Please register or sign in to comment