Removing un-needed semi-colons

Author: kellrott

core/src/main/scala/org/apache/spark/CacheManager.scala

@@ -77,8 +77,8 @@ private[spark] class CacheManager(blockManager: BlockManager) extends Logging {
               case Some(values) =>
                 return new InterruptibleIterator(context, values.asInstanceOf[Iterator[T]])
               case None =>
-                logInfo("Failure to store %s".format(key));
-                return null;
+                logInfo("Failure to store %s".format(key))
+                return null
             }
           } else {
             val elements = new ArrayBuffer[Any]

core/src/main/scala/org/apache/spark/serializer/JavaSerializer.scala

@@ -25,19 +25,19 @@ import org.apache.spark.SparkConf
 
 private[spark] class JavaSerializationStream(out: OutputStream) extends SerializationStream {
   val objOut = new ObjectOutputStream(out)
-  var counter = 0;
+  var counter = 0
   /* Calling reset to avoid memory leak:
    * http://stackoverflow.com/questions/1281549/memory-leak-traps-in-the-java-standard-api
    * But only call it every 1000th time to avoid bloated serialization streams (when
    * the stream 'resets' object class descriptions have to be re-written)  
    */
   def writeObject[T](t: T): SerializationStream = {
-    objOut.writeObject(t);
+    objOut.writeObject(t)
     if (counter >= 1000) {
-      objOut.reset();
-      counter = 0;
+      objOut.reset()
+      counter = 0
     } else {
-      counter+=1;
+      counter += 1
     }
     this
   }

core/src/main/scala/org/apache/spark/storage/MemoryStore.scala

@@ -71,8 +71,8 @@ private class MemoryStore(blockManager: BlockManager, maxMemory: Long)
     : PutResult = {
 
     if (level.deserialized) {
-      val valueEntries = new ArrayBuffer[Any]();
-      valueEntries ++= values;
+      val valueEntries = new ArrayBuffer[Any]()
+      valueEntries ++= values
       val sizeEstimate = SizeEstimator.estimate(valueEntries.asInstanceOf[AnyRef])
       tryToPut(blockId, valueEntries, sizeEstimate, true)
       PutResult(sizeEstimate, Left(valueEntries.toIterator))