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/07/17 02:31:00 UTC
[03/50] [abbrv] git commit: Minor style fix
Minor style fix
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/08150f19
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/08150f19
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/08150f19
Branch: refs/heads/master
Commit: 08150f19abcf08f2a18305080b08736fb8a33a12
Parents: 6855338
Author: Patrick Wendell <pw...@gmail.com>
Authored: Fri Jul 12 19:32:35 2013 -0700
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Fri Jul 12 19:32:35 2013 -0700
----------------------------------------------------------------------
core/src/main/scala/spark/storage/StorageUtils.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/08150f19/core/src/main/scala/spark/storage/StorageUtils.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/spark/storage/StorageUtils.scala b/core/src/main/scala/spark/storage/StorageUtils.scala
index 3e7fa28..aca16f5 100644
--- a/core/src/main/scala/spark/storage/StorageUtils.scala
+++ b/core/src/main/scala/spark/storage/StorageUtils.scala
@@ -47,8 +47,8 @@ object StorageUtils {
/* Returns a map of blocks to their locations, compiled from a list of StorageStatus objects */
def blockLocationsFromStorageStatus(storageStatusList: Seq[StorageStatus]) = {
- val blockLocationPairs = storageStatusList
- .flatMap(s => s.blocks.map(b => (b._1, s.blockManagerId.hostPort)))
+ val blockLocationPairs = storageStatusList
+ .flatMap(s => s.blocks.map(b => (b._1, s.blockManagerId.hostPort)))
blockLocationPairs.groupBy(_._1).map{case (k, v) => (k, v.unzip._2)}.toMap
}