accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject git commit: ACCUMULO-1685 properly parse logSet data for confirming deletes
Date Thu, 05 Sep 2013 15:23:12 GMT
Updated Branches:
  refs/heads/master 53a29837d -> ff02d20db


ACCUMULO-1685 properly parse logSet data for confirming deletes


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

Branch: refs/heads/master
Commit: ff02d20db00dfa00929365e1b7befc5ebb91f76f
Parents: 53a2983
Author: Eric Newton <ecn@apache.org>
Authored: Thu Sep 5 11:23:24 2013 -0400
Committer: Eric Newton <ecn@apache.org>
Committed: Thu Sep 5 11:23:24 2013 -0400

----------------------------------------------------------------------
 .../apache/accumulo/server/gc/GarbageCollectWriteAheadLogs.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/accumulo/blob/ff02d20d/server/src/main/java/org/apache/accumulo/server/gc/GarbageCollectWriteAheadLogs.java
----------------------------------------------------------------------
diff --git a/server/src/main/java/org/apache/accumulo/server/gc/GarbageCollectWriteAheadLogs.java
b/server/src/main/java/org/apache/accumulo/server/gc/GarbageCollectWriteAheadLogs.java
index 7dba265..2ce40b5 100644
--- a/server/src/main/java/org/apache/accumulo/server/gc/GarbageCollectWriteAheadLogs.java
+++ b/server/src/main/java/org/apache/accumulo/server/gc/GarbageCollectWriteAheadLogs.java
@@ -226,7 +226,9 @@ public class GarbageCollectWriteAheadLogs {
     int count = 0;
     Iterator<LogEntry> iterator = MetadataTableUtil.getLogEntries(SystemCredentials.get());
     while (iterator.hasNext()) {
-      for (String filename : iterator.next().logSet) {
+      for (String entry : iterator.next().logSet) {
+        String parts[] = entry.split("/", 2);
+        String filename = parts[1];
         Path path;
         if (filename.contains(":"))
           path = new Path(filename);


Mime
View raw message