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 <[email protected]> Authored: Mon Nov 11 15:49:32 2013 +0800 Committer: Andrew xia <[email protected]> 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>
