You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by kt...@apache.org on 2012/02/03 22:14:13 UTC
svn commit: r1240342 -
/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
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));
}
}
}