aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorReynold Xin <rxin@cs.berkeley.edu>2013-05-07 18:40:35 -0700
committerReynold Xin <rxin@cs.berkeley.edu>2013-05-07 18:40:35 -0700
commit8388e8dd7ab5e55ea67b329d9359ba2147d796b0 (patch)
treedea91b7ca8554daae62b492e1670706e6690ea62
parent547dcbe494ce7a888f636cf2596243be37b567b1 (diff)
downloadspark-8388e8dd7ab5e55ea67b329d9359ba2147d796b0.tar.gz
spark-8388e8dd7ab5e55ea67b329d9359ba2147d796b0.tar.bz2
spark-8388e8dd7ab5e55ea67b329d9359ba2147d796b0.zip
Minor style fix in DiskStore...
-rw-r--r--core/src/main/scala/spark/storage/DiskStore.scala4
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
}