diff options
author | Reynold Xin <rxin@cs.berkeley.edu> | 2013-05-07 18:40:35 -0700 |
---|---|---|
committer | Reynold Xin <rxin@cs.berkeley.edu> | 2013-05-07 18:40:35 -0700 |
commit | 8388e8dd7ab5e55ea67b329d9359ba2147d796b0 (patch) | |
tree | dea91b7ca8554daae62b492e1670706e6690ea62 /core | |
parent | 547dcbe494ce7a888f636cf2596243be37b567b1 (diff) | |
download | spark-8388e8dd7ab5e55ea67b329d9359ba2147d796b0.tar.gz spark-8388e8dd7ab5e55ea67b329d9359ba2147d796b0.tar.bz2 spark-8388e8dd7ab5e55ea67b329d9359ba2147d796b0.zip |
Minor style fix in DiskStore...
Diffstat (limited to 'core')
-rw-r--r-- | core/src/main/scala/spark/storage/DiskStore.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/main/scala/spark/storage/DiskStore.scala b/core/src/main/scala/spark/storage/DiskStore.scala index be33d4260e..933eeaa216 100644 --- a/core/src/main/scala/spark/storage/DiskStore.scala +++ b/core/src/main/scala/spark/storage/DiskStore.scala @@ -283,7 +283,7 @@ private class DiskStore(blockManager: BlockManager, rootDirs: String) }) } - private def startShuffleBlockSender (){ + private def startShuffleBlockSender() { try { val port = System.getProperty("spark.shuffle.sender.port", "6653").toInt @@ -297,7 +297,7 @@ private class DiskStore(blockManager: BlockManager, rootDirs: String) } shuffleSender = new Thread { override def run() = { - val sender = new ShuffleSender(port,pResolver) + val sender = new ShuffleSender(port, pResolver) logInfo("Created ShuffleSender binding to port : "+ port) sender.start } |