diff options
| author | Andrew xia <junluan.xia@intel.com> | 2013-11-11 15:49:32 +0800 |
|---|---|---|
| committer | Andrew xia <junluan.xia@intel.com> | 2013-11-11 15:49:32 +0800 |
| commit | 37d2f3749eec583acb23b6b1e0a5b453170fc965 (patch) | |
| tree | 84a19d3f921a62e3c4cec4a9d3088e4fd752c862 | |
| parent | b3208063afe7190efd6e54a41b7af28d15c46358 (diff) | |
| download | spark-37d2f3749eec583acb23b6b1e0a5b453170fc965.tar.gz spark-37d2f3749eec583acb23b6b1e0a5b453170fc965.tar.bz2 spark-37d2f3749eec583acb23b6b1e0a5b453170fc965.zip | |
cut lines to less than 100
| -rw-r--r-- | core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala | 6 |
1 files changed, 4 insertions, 2 deletions
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 9316465734..964843eb60 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> |