accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject [1/2] git commit: ACCUMULO-1740 no idea why this fixes the hangs we've seen
Date Fri, 27 Sep 2013 17:41:07 GMT
Updated Branches:
  refs/heads/master acba59b16 -> 9ac95f869


ACCUMULO-1740 no idea why this fixes the hangs we've seen


Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/e5e5b2bc
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/e5e5b2bc
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/e5e5b2bc

Branch: refs/heads/master
Commit: e5e5b2bc39be0c500e18880d7e1821f2903bfb2d
Parents: acba59b
Author: Eric Newton <eric.newton@gmail.com>
Authored: Fri Sep 27 13:40:08 2013 -0400
Committer: Eric Newton <eric.newton@gmail.com>
Committed: Fri Sep 27 13:40:08 2013 -0400

----------------------------------------------------------------------
 .../org/apache/accumulo/server/tabletserver/TabletServer.java  | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/e5e5b2bc/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
b/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
index ce22534..575d7e7 100644
--- a/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
+++ b/server/src/main/java/org/apache/accumulo/server/tabletserver/TabletServer.java
@@ -66,6 +66,8 @@ import org.apache.accumulo.core.client.AccumuloSecurityException;
 import org.apache.accumulo.core.client.Instance;
 import org.apache.accumulo.core.client.impl.CompressedIterators;
 import org.apache.accumulo.core.client.impl.CompressedIterators.IterConfig;
+import org.apache.accumulo.core.client.impl.Translator.TKeyExtentTranslator;
+import org.apache.accumulo.core.client.impl.Translator.TRangeTranslator;
 import org.apache.accumulo.core.client.impl.ScannerImpl;
 import org.apache.accumulo.core.client.impl.TabletType;
 import org.apache.accumulo.core.client.impl.Translator;
@@ -1325,8 +1327,8 @@ public class TabletServer extends AbstractMetricsImpl implements org.apache.accu
       for (ByteBuffer auth : authorizations)
         if (!userauths.contains(ByteBufferUtil.toBytes(auth)))
           throw new ThriftSecurityException(credentials.getPrincipal(), SecurityErrorCode.BAD_AUTHORIZATIONS);
-      
-      Map<KeyExtent,List<Range>> batch = Translator.translate(tbatch, Translator.TKET,
new Translator.ListTranslator<TRange,Range>(Translator.TRT));
+
+      Map<KeyExtent,List<Range>> batch = Translator.translate(tbatch, new TKeyExtentTranslator(),
new Translator.ListTranslator<TRange,Range>(new TRangeTranslator()));
       
       // This is used to determine which thread pool to use
       KeyExtent threadPoolExtent = batch.keySet().iterator().next();


Mime
View raw message