keith-turner commented on PR #5813: URL: https://github.com/apache/accumulo/pull/5813#issuecomment-3212637373
Opened #5816 after looking into the failure and making the following changes locally from https://github.com/apache/accumulo/commit/3a0d8e5c72915fb4c7ce26d6156d15b0a444fb71. Ran the test and got it time out and saw the same odd stack traces again the first time it printed, but they were not there the second time. Also w/ the extra logging for the catch saw a test failure that I have not looked into yet. The exception from the assertion in the finallly was obscuring any exceptions from the test. ```diff diff --git a/test/src/main/java/org/apache/accumulo/test/fate/FatePoolsWatcherITBase.java b/test/src/main/java/org/apache/accumulo/test/fate/FatePoolsWatcherITBase.java index a4fb0b8f9e..72fc00f57f 100644 --- a/test/src/main/java/org/apache/accumulo/test/fate/FatePoolsWatcherITBase.java +++ b/test/src/main/java/org/apache/accumulo/test/fate/FatePoolsWatcherITBase.java @@ -36,6 +36,7 @@ import org.apache.accumulo.core.fate.FateId; import org.apache.accumulo.core.fate.FateInstanceType; import org.apache.accumulo.core.fate.FateStore; import org.apache.accumulo.core.fate.Repo; +import org.apache.accumulo.core.util.UtilWaitThread; import org.apache.accumulo.harness.SharedMiniClusterBase; import org.apache.accumulo.server.ServerContext; import org.apache.accumulo.test.util.Wait; @@ -171,8 +172,31 @@ public abstract class FatePoolsWatcherITBase extends SharedMiniClusterBase assertEquals(0, fate.getTxRunnersActive(set2)); assertEquals(numWorkersSet3, fate.getTxRunnersActive(set3)); assertEquals(numWorkersSet4, fate.getTxRunnersActive(set4)); + } catch (Throwable e) { + System.err.println("SAW ERROR"); + e.printStackTrace(); + throw e; } finally { fate.shutdown(30, TimeUnit.SECONDS); + if (fate.getTotalTxRunnersActive() > 0) { + System.out.println("BEGIN STACKS 1"); + Thread.getAllStackTraces().forEach((t, se) -> { + System.out.println(" " + t.getName()); + for (var e : se) { + System.out.println("\t" + e); + } + }); + System.out.println("END STACKS 1"); + UtilWaitThread.sleep(2000); + System.out.println("BEGIN STACKS 2"); + Thread.getAllStackTraces().forEach((t, se) -> { + System.out.println(" " + t.getName()); + for (var e : se) { + System.out.println("\t" + e); + } + }); + System.out.println("END STACKS 2"); + } assertEquals(0, fate.getTotalTxRunnersActive()); } } ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
