accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject git commit: ACCUMULO-1732 fix AccumuloInputFormatIT
Date Fri, 18 Oct 2013 21:47:19 GMT
Updated Branches:
  refs/heads/master a9a371b1e -> 3e74ee665


ACCUMULO-1732 fix AccumuloInputFormatIT


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

Branch: refs/heads/master
Commit: 3e74ee6654b879ca4eccf7b6f5469d4fa92b4b66
Parents: a9a371b
Author: Eric Newton <eric.newton@gmail.com>
Authored: Fri Oct 18 17:47:40 2013 -0400
Committer: Eric Newton <eric.newton@gmail.com>
Committed: Fri Oct 18 17:47:40 2013 -0400

----------------------------------------------------------------------
 .../apache/accumulo/core/client/mapreduce/AbstractInputFormat.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/3e74ee66/core/src/main/java/org/apache/accumulo/core/client/mapreduce/AbstractInputFormat.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/accumulo/core/client/mapreduce/AbstractInputFormat.java
b/core/src/main/java/org/apache/accumulo/core/client/mapreduce/AbstractInputFormat.java
index c07a62e..889dcbb 100644
--- a/core/src/main/java/org/apache/accumulo/core/client/mapreduce/AbstractInputFormat.java
+++ b/core/src/main/java/org/apache/accumulo/core/client/mapreduce/AbstractInputFormat.java
@@ -605,11 +605,11 @@ public abstract class AbstractInputFormat<K,V> extends InputFormat<K,V>
{
 
           while (!tl.binRanges(creds, ranges, binnedRanges).isEmpty()) {
             if (!(instance instanceof MockInstance)) {
+              tableId = Tables.getTableId(instance, tableName);
               if (!Tables.exists(instance, tableId))
                 throw new TableDeletedException(tableId);
               if (Tables.getTableState(instance, tableId) == TableState.OFFLINE)
                 throw new TableOfflineException(instance, tableId);
-              tableId = Tables.getTableId(instance, tableName);
             }
             binnedRanges.clear();
             log.warn("Unable to locate bins for specified ranges. Retrying.");


Mime
View raw message