You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hbase.apache.org by la...@apache.org on 2013/01/14 06:31:40 UTC

svn commit: r1432806 - /hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java

Author: larsh
Date: Mon Jan 14 05:31:39 2013
New Revision: 1432806

URL: http://svn.apache.org/viewvc?rev=1432806&view=rev
Log:
HBASE-7550 Synchronization problem in AssignmentManager

Modified:
    hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java

Modified: hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java?rev=1432806&r1=1432805&r2=1432806&view=diff
==============================================================================
--- hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java (original)
+++ hbase/branches/0.94/src/main/java/org/apache/hadoop/hbase/master/AssignmentManager.java Mon Jan 14 05:31:39 2013
@@ -1161,7 +1161,9 @@ public class AssignmentManager extends Z
         } else if (rs.isSplitting()) {
           LOG.debug("Ephemeral node deleted.  Found in SPLITTING state. " + "Removing from RIT "
               + rs.getRegion());
-          this.regionsInTransition.remove(regionName);
+          synchronized(this.regionsInTransition) {
+            this.regionsInTransition.remove(regionName);
+          }
         } else {
           LOG.debug("The znode of region " + regionInfo.getRegionNameAsString()
               + " has been deleted.");