You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by el...@apache.org on 2014/05/21 03:59:49 UTC
[30/50] [abbrv] git commit: ACCUMULO-378 Remove busted logic in
status tracking after MinC
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 <el...@apache.org>
Authored: Mon May 19 13:53:22 2014 -0400
Committer: Josh Elser <el...@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());
}
}