You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by ec...@apache.org on 2015/06/24 18:16:19 UTC
accumulo git commit: ACCUMULO-3911 change tests to be consistent with
more knowledge about the state of the WALs
Repository: accumulo
Updated Branches:
refs/heads/master 29fdbfbb7 -> 245d724ad
ACCUMULO-3911 change tests to be consistent with more knowledge about the state of the WALs
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo
Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/245d724a
Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/245d724a
Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/245d724a
Branch: refs/heads/master
Commit: 245d724ad7e2ac7b12c243bb6f9718c656bc29bf
Parents: 29fdbfb
Author: Eric Newton <er...@gmail.com>
Authored: Wed Jun 24 12:15:44 2015 -0400
Committer: Eric Newton <er...@gmail.com>
Committed: Wed Jun 24 12:15:44 2015 -0400
----------------------------------------------------------------------
.../gc/replication/CloseWriteAheadLogReferencesTest.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/accumulo/blob/245d724a/server/gc/src/test/java/org/apache/accumulo/gc/replication/CloseWriteAheadLogReferencesTest.java
----------------------------------------------------------------------
diff --git a/server/gc/src/test/java/org/apache/accumulo/gc/replication/CloseWriteAheadLogReferencesTest.java b/server/gc/src/test/java/org/apache/accumulo/gc/replication/CloseWriteAheadLogReferencesTest.java
index af8a9d0..7460b66 100644
--- a/server/gc/src/test/java/org/apache/accumulo/gc/replication/CloseWriteAheadLogReferencesTest.java
+++ b/server/gc/src/test/java/org/apache/accumulo/gc/replication/CloseWriteAheadLogReferencesTest.java
@@ -111,7 +111,7 @@ public class CloseWriteAheadLogReferencesTest {
}
@Test
- public void unusedWalsAreClosed() throws Exception {
+ public void unclosedWalsLeaveStatusOpen() throws Exception {
Set<String> wals = Collections.emptySet();
Instance inst = new MockInstance(testName.getMethodName());
Connector conn = inst.getConnector("root", new PasswordToken(""));
@@ -127,11 +127,11 @@ public class CloseWriteAheadLogReferencesTest {
Scanner s = conn.createScanner(MetadataTable.NAME, Authorizations.EMPTY);
Entry<Key,Value> entry = Iterables.getOnlyElement(s);
Status status = Status.parseFrom(entry.getValue().get());
- Assert.assertTrue(status.getClosed());
+ Assert.assertFalse(status.getClosed());
}
@Test
- public void usedWalsAreNotClosed() throws Exception {
+ public void closedWalsUpdateStatus() throws Exception {
String file = "file:/accumulo/wal/tserver+port/12345";
Set<String> wals = Collections.singleton(file);
Instance inst = new MockInstance(testName.getMethodName());
@@ -148,7 +148,7 @@ public class CloseWriteAheadLogReferencesTest {
Scanner s = conn.createScanner(MetadataTable.NAME, Authorizations.EMPTY);
Entry<Key,Value> entry = Iterables.getOnlyElement(s);
Status status = Status.parseFrom(entry.getValue().get());
- Assert.assertFalse(status.getClosed());
+ Assert.assertTrue(status.getClosed());
}
@Test