diff options
| -rw-r--r-- | conf/java-opts.template | 1 | ||||
| -rwxr-xr-x | conf/spark-env.sh.template | 2 | ||||
| -rw-r--r-- | src/scala/spark/Broadcast.scala | 2 |
3 files changed, 2 insertions, 3 deletions
diff --git a/conf/java-opts.template b/conf/java-opts.template index b61e8163b5..e69de29bb2 100644 --- a/conf/java-opts.template +++ b/conf/java-opts.template @@ -1 +0,0 @@ --Dspark.broadcast.masterHostAddress=127.0.0.1 -Dspark.broadcast.masterTrackerPort=11111 -Dspark.broadcast.blockSize=1024 -Dspark.broadcast.maxRetryCount=2 -Dspark.broadcast.serverSocketTimout=50000 -Dspark.broadcast.dualMode=false diff --git a/conf/spark-env.sh.template b/conf/spark-env.sh.template index 77f9cb69b9..6852b23a34 100755 --- a/conf/spark-env.sh.template +++ b/conf/spark-env.sh.template @@ -10,4 +10,4 @@ # be in the same format as the JVM's -Xmx option, e.g. 300m or 1g). # - SPARK_LIBRARY_PATH, to add extra search paths for native libraries. -MESOS_HOME=/home/mosharaf/Work/mesos + diff --git a/src/scala/spark/Broadcast.scala b/src/scala/spark/Broadcast.scala index 105aa3483e..df7ab3f19f 100644 --- a/src/scala/spark/Broadcast.scala +++ b/src/scala/spark/Broadcast.scala @@ -223,7 +223,7 @@ private object Broadcast { // Initialization for CentralizedHDFSBroadcast BroadcastCH.initialize // Initialization for ChainedStreamingBroadcast - BroadcastCS.initialize (isMaster) + // BroadcastCS.initialize (isMaster) initialized = true } |