You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by ma...@apache.org on 2013/11/13 01:20:44 UTC
[2/4] git commit: cut lines to less than 100
cut lines to less than 100
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/37d2f374
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/37d2f374
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/37d2f374
Branch: refs/heads/master
Commit: 37d2f3749eec583acb23b6b1e0a5b453170fc965
Parents: b320806
Author: Andrew xia <ju...@intel.com>
Authored: Mon Nov 11 15:49:32 2013 +0800
Committer: Andrew xia <ju...@intel.com>
Committed: Mon Nov 11 15:49:32 2013 +0800
----------------------------------------------------------------------
core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/37d2f374/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
index 9316465..964843e 100644
--- a/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
+++ b/core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala
@@ -156,14 +156,16 @@ private[spark] class StagePage(parent: JobProgressUI) {
var shuffleReadReadable: String = ""
if (shuffleRead) {
shuffleReadSortable = metrics.flatMap{m => m.shuffleReadMetrics}.map{s => s.remoteBytesRead}.toString()
- shuffleReadReadable = metrics.flatMap{m => m.shuffleReadMetrics}.map{s =>Utils.bytesToString(s.remoteBytesRead)}.getOrElse("")
+ shuffleReadReadable = metrics.flatMap{m => m.shuffleReadMetrics}.map{s =>
+ Utils.bytesToString(s.remoteBytesRead)}.getOrElse("")
}
var shuffleWriteSortable: String = ""
var shuffleWriteReadable: String = ""
if (shuffleWrite) {
shuffleWriteSortable = metrics.flatMap{m => m.shuffleWriteMetrics}.map{s => s.shuffleBytesWritten}.toString()
- shuffleWriteReadable = metrics.flatMap{m => m.shuffleWriteMetrics}.map{s =>Utils.bytesToString(s.shuffleBytesWritten)}.getOrElse("")
+ shuffleWriteReadable = metrics.flatMap{m => m.shuffleWriteMetrics}.map{s =>
+ Utils.bytesToString(s.shuffleBytesWritten)}.getOrElse("")
}
<tr>