Remove unnecessary synchronized

apache · Jul 1, 2015 · fcf7b50 · fcf7b50
1 parent 3bee0f1
commit fcf7b50
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/core/src/main/scala/org/apache/spark/deploy/master/Master.scala b/core/src/main/scala/org/apache/spark/deploy/master/Master.scala
@@ -518,12 +518,9 @@ private[master] class Master(
   }
 
   private def completeRecovery() {
-    // TODO Why synchronized
     // Ensure "only-once" recovery semantics using a short synchronization period.
-    synchronized {
-      if (state != RecoveryState.RECOVERING) { return }
-      state = RecoveryState.COMPLETING_RECOVERY
-    }
+    if (state != RecoveryState.RECOVERING) { return }
+    state = RecoveryState.COMPLETING_RECOVERY
 
     // Kill off any workers and apps that didn't respond to us.
     workers.filter(_.state == WorkerState.UNKNOWN).foreach(removeWorker)