ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Bug fix + minor changes

Browse source
This commit is contained in:
Mosharaf Chowdhury 2010-11-06 16:54:55 -07:00
parent 878d157ce3
commit c37c74919f
2 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
conf/java-opts
View file

@ -1 +1 @@
-Dspark.broadcast.MasterHostAddress=127.0.0.1 -Dspark.broadcast.MasterTrackerPort=11111 -Dspark.broadcast.BlockSize=256 -Dspark.broadcast.MaxRetryCount=2 -Dspark.broadcast.TrackerSocketTimeout=50000 -Dspark.broadcast.ServerSocketTimout=10000 -Dspark.broadcast.MaxChatTime=500
-Dspark.broadcast.MasterHostAddress=127.0.0.1 -Dspark.broadcast.MasterTrackerPort=11111 -Dspark.broadcast.BlockSize=256 -Dspark.broadcast.MaxRetryCount=2 -Dspark.broadcast.TrackerSocketTimeout=50000 -Dspark.broadcast.ServerSocketTimeout=10000 -Dspark.broadcast.MaxChatTime=500

8
src/scala/spark/Broadcast.scala
View file

@ -669,7 +669,7 @@ extends BroadcastRecipe with Logging {
}
}
if (clientSocket != null) {
logInfo ("Guide:Accepted new client connection:" + clientSocket)
logInfo ("Guide: Accepted new client connection:" + clientSocket)
try {
threadPool.execute (new GuideSingleRequest (clientSocket))
} catch {
@ -824,7 +824,7 @@ extends BroadcastRecipe with Logging {
}
}
if (clientSocket != null) {
logInfo ("Serve:Accepted new client connection:" + clientSocket)
logInfo ("Serve: Accepted new client connection:" + clientSocket)
try {
threadPool.execute (new ServeSingleRequest (clientSocket))
} catch {
@ -1000,7 +1000,7 @@ extends BroadcastRecipe with Logging {
@serializable
case class SourceInfo (val hostAddress: String, val listenPort: Int,
val totalBlocks: Int, val totalBytes: Int)
extends Logging {
extends Logging {
var currentLeechers = 0
var receptionFailed = false
@ -1164,7 +1164,7 @@ extends Logging {
trackMV = new TrackMultipleValues
trackMV.setDaemon (true)
trackMV.start
logInfo ("TrackMultipleValues started")
logInfo ("TrackMultipleValues started...")
}
initialized = true