ACCUMULO-2507 add debugging information, and timeout for reader thread to pull in all the output of the tserver
Project: http://git-wip-us.apache.org/repos/asf/accumulo/repo Commit: http://git-wip-us.apache.org/repos/asf/accumulo/commit/acce1d53 Tree: http://git-wip-us.apache.org/repos/asf/accumulo/tree/acce1d53 Diff: http://git-wip-us.apache.org/repos/asf/accumulo/diff/acce1d53 Branch: refs/heads/master Commit: acce1d53f54dbb88804caf4b35f8eaac01252f5e Parents: 0fb0369 Author: Eric C. Newton <eric.new...@gmail.com> Authored: Thu Mar 20 14:25:34 2014 -0400 Committer: Eric C. Newton <eric.new...@gmail.com> Committed: Thu Mar 20 14:26:06 2014 -0400 ---------------------------------------------------------------------- .../accumulo/test/functional/HalfDeadTServerIT.java | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/accumulo/blob/acce1d53/test/src/test/java/org/apache/accumulo/test/functional/HalfDeadTServerIT.java ---------------------------------------------------------------------- diff --git a/test/src/test/java/org/apache/accumulo/test/functional/HalfDeadTServerIT.java b/test/src/test/java/org/apache/accumulo/test/functional/HalfDeadTServerIT.java index d08b822..0346f2f 100644 --- a/test/src/test/java/org/apache/accumulo/test/functional/HalfDeadTServerIT.java +++ b/test/src/test/java/org/apache/accumulo/test/functional/HalfDeadTServerIT.java @@ -16,8 +16,7 @@ */ package org.apache.accumulo.test.functional; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertTrue; +import static org.junit.Assert.*; import java.io.BufferedReader; import java.io.File; @@ -94,8 +93,13 @@ public class HalfDeadTServerIT extends ConfigurableMacIT { @Test(timeout = 4 * 60 * 1000) public void testTimeout() throws Exception { String results = test(40); - if (results != null) - assertTrue(results.contains("Session expired")); + if (results != null) { + if (!results.contains("Session expired")) { + System.out.println("Failed to find Session expired in"); + System.out.println(results); + fail("zookeeper session failed to expire"); + } + } } public String test(int seconds) throws Exception { @@ -169,6 +173,7 @@ public class HalfDeadTServerIT extends ConfigurableMacIT { tserver.destroy(); tserver.waitFor(); t.join(); + UtilWaitThread.sleep(1000); } }
