incubator-accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ktur...@apache.org
Subject svn commit: r1240342 - /incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
Date Fri, 03 Feb 2012 21:14:13 GMT
Author: kturner
Date: Fri Feb  3 21:14:13 2012
New Revision: 1240342

URL: http://svn.apache.org/viewvc?rev=1240342&view=rev
Log:
ACCUMULO-368 set tablet location in metadata before brining tablet online in tablet server
instead of after

Modified:
    incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java

Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java?rev=1240342&r1=1240341&r2=1240342&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
(original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
Fri Feb  3 21:14:13 2012
@@ -2399,6 +2399,9 @@ public class TabletServer extends Abstra
             tablet.waitForMinC();
           }
           
+          Assignment assignment = new Assignment(extentToOpen, getTabletSession());
+          TabletStateStore.setLocation(assignment);
+
           synchronized (openingTablets) {
             synchronized (onlineTablets) {
               openingTablets.remove(extentToOpen);
@@ -2445,13 +2448,7 @@ public class TabletServer extends Abstra
             }
           }, reschedule);
         } else {
-          try {
-            Assignment assignment = new Assignment(extentToOpen, getTabletSession());
-            TabletStateStore.setLocation(assignment);
-            enqueueMasterMessage(new TabletStatusMessage(TabletLoadState.LOADED, extentToOpen));
-          } catch (DistributedStoreException ex) {
-            log.warn("Unable to update storage", ex);
-          }
+          enqueueMasterMessage(new TabletStatusMessage(TabletLoadState.LOADED, extentToOpen));
         }
       }
     }



Mime
View raw message