Skip to content
Snippets Groups Projects
Commit 8388e8dd authored by Reynold Xin's avatar Reynold Xin
Browse files

Minor style fix in DiskStore...

parent 547dcbe4
No related branches found
No related tags found
No related merge requests found
......@@ -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
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment