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 <[email protected]> Authored: Thu Sep 5 11:23:24 2013 -0400 Committer: Eric Newton <[email protected]> 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);
