accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ktur...@apache.org
Subject svn commit: r1466259 - /accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/iterators/MetadataBulkLoadFilter.java
Date Tue, 09 Apr 2013 21:56:28 GMT
Author: kturner
Date: Tue Apr  9 21:56:28 2013
New Revision: 1466259

URL: http://svn.apache.org/r1466259
Log:
ACCUMULO-1044 fixed bug in bulk load filter

Modified:
    accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/iterators/MetadataBulkLoadFilter.java

Modified: accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/iterators/MetadataBulkLoadFilter.java
URL: http://svn.apache.org/viewvc/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/iterators/MetadataBulkLoadFilter.java?rev=1466259&r1=1466258&r2=1466259&view=diff
==============================================================================
--- accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/iterators/MetadataBulkLoadFilter.java
(original)
+++ accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/iterators/MetadataBulkLoadFilter.java
Tue Apr  9 21:56:28 2013
@@ -50,10 +50,10 @@ public class MetadataBulkLoadFilter exte
       Status status = bulkTxStatusCache.get(txid);
       if (status == null) {
         try {
-          if (arbitrator.transactionAlive(Constants.BULK_ARBITRATOR_TYPE, txid)) {
-            status = Status.ACTIVE;
-          } else {
+          if (arbitrator.transactionComplete(Constants.BULK_ARBITRATOR_TYPE, txid)) {
             status = Status.INACTIVE;
+          } else {
+            status = Status.ACTIVE;
           }
         } catch (Exception e) {
           // TODO log



Mime
View raw message