accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From els...@apache.org
Subject [30/50] [abbrv] git commit: ACCUMULO-378 Remove busted logic in status tracking after MinC
Date Wed, 21 May 2014 01:59:49 GMT
ACCUMULO-378 Remove busted logic in status tracking after MinC

A WAL might still be used after a MinC. It does not signify that the WAL
is closed, only that the data was flushed from the IMM.


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

Branch: refs/heads/ACCUMULO-378
Commit: e1f697dacf96d4878732fd318f416a2423af095c
Parents: 24d9394
Author: Josh Elser <elserj@apache.org>
Authored: Mon May 19 13:53:22 2014 -0400
Committer: Josh Elser <elserj@apache.org>
Committed: Mon May 19 13:53:22 2014 -0400

----------------------------------------------------------------------
 .../src/main/java/org/apache/accumulo/tserver/Tablet.java     | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/e1f697da/server/tserver/src/main/java/org/apache/accumulo/tserver/Tablet.java
----------------------------------------------------------------------
diff --git a/server/tserver/src/main/java/org/apache/accumulo/tserver/Tablet.java b/server/tserver/src/main/java/org/apache/accumulo/tserver/Tablet.java
index 799fb1b..866450c 100644
--- a/server/tserver/src/main/java/org/apache/accumulo/tserver/Tablet.java
+++ b/server/tserver/src/main/java/org/apache/accumulo/tserver/Tablet.java
@@ -890,10 +890,11 @@ public class Tablet {
           MasterMetadataUtil.updateTabletDataFile(extent, newDatafile, absMergeFile, dfv,
time, SystemCredentials.get(), filesInUseByScans,
               tabletServer.getClientAddressString(), tabletServer.getLock(), unusedWalLogs,
lastLocation, flushId);
 
-            // Mark that we have data we want to replicate
-            // This WAL could still be in use by other Tablets though
+          // Mark that we have data we want to replicate
+          // This WAL could still be in use by other Tablets though, so we can mark that
there is data to replicate,
+          // but it is *not* closed
           if (replicate) {
-            ReplicationTableUtil.updateFiles(SystemCredentials.get(), extent, logFileOnly,
StatusUtil.fileClosed(System.currentTimeMillis()));
+            ReplicationTableUtil.updateFiles(SystemCredentials.get(), extent, logFileOnly,
StatusUtil.openWithUnknownLength());
           }
         }
 


Mime
View raw message