keith-turner commented on PR #5813:
URL: https://github.com/apache/accumulo/pull/5813#issuecomment-3212500139
Made the following changes against 3a0d8e5c72915fb4c7ce26d6156d15b0a444fb71
which is the current head of main.
```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..70f6341246 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
@@ -173,6 +173,14 @@ public abstract class FatePoolsWatcherITBase extends
SharedMiniClusterBase
assertEquals(numWorkersSet4, fate.getTxRunnersActive(set4));
} finally {
fate.shutdown(30, TimeUnit.SECONDS);
+ if (fate.getTotalTxRunnersActive() > 0) {
+ Thread.getAllStackTraces().forEach((t, se) -> {
+ System.out.println(" " + t.getName());
+ for (var e : se) {
+ System.out.println("\t" + e);
+ }
+ });
+ }
assertEquals(0, fate.getTotalTxRunnersActive());
}
}
```
Ran the test a few times and then it finally failed and saw the following
odd stack traces in the output in the failsafe dir. These are all of the
stacks that contained FateExecutor. Not sure what is going on w/ the class
loader stuff.
```
accumulo.pool.manager.fate.user.table_create.table_delete.table_delete_range.table_export.table_import.table_merge.table_offline.table_online.table_rename.table_split.table_tablet_availability-Worker-1
java.base@17.0.16/jdk.internal.loader.BuiltinClassLoader.loadClassOrNull(BuiltinClassLoader.java:651)
java.base@17.0.16/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:639)
java.base@17.0.16/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
java.base@17.0.16/java.lang.ClassLoader.loadClass(ClassLoader.java:525)
app//org.apache.accumulo.core.fate.FateExecutor$TransactionRunner.blockIfHadoopShutdown(FateExecutor.java:457)
app//org.apache.accumulo.core.fate.FateExecutor$TransactionRunner.run(FateExecutor.java:390)
app//org.apache.accumulo.core.trace.TraceWrappedRunnable.run(TraceWrappedRunnable.java:52)
java.base@17.0.16/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
java.base@17.0.16/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
app//org.apache.accumulo.core.trace.TraceWrappedRunnable.run(TraceWrappedRunnable.java:52)
java.base@17.0.16/java.lang.Thread.run(Thread.java:840)
accumulo.pool.manager.fate.user.table_create.table_delete.table_delete_range.table_export.table_import.table_merge.table_offline.table_online.table_rename.table_split.table_tablet_availability-Worker-4
app//org.apache.logging.log4j.core.pattern.DatePatternConverter$CachedTime.<init>(DatePatternConverter.java:166)
app//org.apache.logging.log4j.core.pattern.DatePatternConverter.formatWithoutThreadLocals(DatePatternConverter.java:330)
app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:309)
app//org.apache.logging.log4j.core.pattern.DatePatternConverter.format(DatePatternConverter.java:284)
app//org.apache.logging.log4j.core.pattern.PatternFormatter.format(PatternFormatter.java:44)
app//org.apache.logging.log4j.core.layout.PatternLayout$PatternFormatterPatternSerializer.toSerializable(PatternLayout.java:397)
app//org.apache.logging.log4j.core.layout.PatternLayout.toText(PatternLayout.java:252)
app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:238)
app//org.apache.logging.log4j.core.layout.PatternLayout.encode(PatternLayout.java:58)
app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.directEncodeEvent(AbstractOutputStreamAppender.java:227)
app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.tryAppend(AbstractOutputStreamAppender.java:220)
app//org.apache.logging.log4j.core.appender.AbstractOutputStreamAppender.append(AbstractOutputStreamAppender.java:211)
app//org.apache.logging.log4j.core.config.AppenderControl.tryCallAppender(AppenderControl.java:160)
app//org.apache.logging.log4j.core.config.AppenderControl.callAppender0(AppenderControl.java:133)
app//org.apache.logging.log4j.core.config.AppenderControl.callAppenderPreventRecursion(AppenderControl.java:124)
app//org.apache.logging.log4j.core.config.AppenderControl.callAppender(AppenderControl.java:88)
app//org.apache.logging.log4j.core.config.LoggerConfig.callAppenders(LoggerConfig.java:714)
app//org.apache.logging.log4j.core.config.LoggerConfig.processLogEvent(LoggerConfig.java:672)
app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:648)
app//org.apache.logging.log4j.core.config.LoggerConfig.logParent(LoggerConfig.java:705)
app//org.apache.logging.log4j.core.config.LoggerConfig.processLogEvent(LoggerConfig.java:674)
app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:648)
app//org.apache.logging.log4j.core.config.LoggerConfig.log(LoggerConfig.java:584)
app//org.apache.logging.log4j.core.config.AwaitCompletionReliabilityStrategy.log(AwaitCompletionReliabilityStrategy.java:92)
app//org.apache.logging.log4j.core.Logger.log(Logger.java:187)
app//org.apache.logging.log4j.spi.AbstractLogger.tryLogMessage(AbstractLogger.java:2904)
app//org.apache.logging.log4j.spi.AbstractLogger.logMessageTrackRecursion(AbstractLogger.java:2857)
app//org.apache.logging.log4j.spi.AbstractLogger.logMessageSafely(AbstractLogger.java:2839)
app//org.apache.logging.log4j.spi.AbstractLogger.logMessage(AbstractLogger.java:2618)
app//org.apache.logging.log4j.spi.AbstractLogger.logIfEnabled(AbstractLogger.java:2565)
app//org.apache.logging.slf4j.Log4jLogger.error(Log4jLogger.java:313)
app//org.apache.accumulo.core.fate.FateExecutor$TransactionRunner.run(FateExecutor.java:406)
app//org.apache.accumulo.core.trace.TraceWrappedRunnable.run(TraceWrappedRunnable.java:52)
java.base@17.0.16/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
java.base@17.0.16/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
app//org.apache.accumulo.core.trace.TraceWrappedRunnable.run(TraceWrappedRunnable.java:52)
java.base@17.0.16/java.lang.Thread.run(Thread.java:840)
accumulo.pool.manager.fate.user.commit_compaction.namespace_create.namespace_delete.namespace_rename.shutdown_tserver.system_split.system_merge.table_bulk_import2.table_cancel_compact.table_clone.table_compact-Worker-1
java.base@17.0.16/jdk.internal.loader.BuiltinClassLoader.defineClass(BuiltinClassLoader.java:842)
java.base@17.0.16/jdk.internal.loader.BuiltinClassLoader.findClassOnClassPathOrNull(BuiltinClassLoader.java:760)
java.base@17.0.16/jdk.internal.loader.BuiltinClassLoader.loadClassOrNull(BuiltinClassLoader.java:681)
java.base@17.0.16/jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:639)
java.base@17.0.16/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188)
java.base@17.0.16/java.lang.ClassLoader.loadClass(ClassLoader.java:525)
app//org.apache.accumulo.core.fate.FateExecutor$TransactionRunner.blockIfHadoopShutdown(FateExecutor.java:457)
app//org.apache.accumulo.core.fate.FateExecutor$TransactionRunner.run(FateExecutor.java:390)
app//org.apache.accumulo.core.trace.TraceWrappedRunnable.run(TraceWrappedRunnable.java:52)
java.base@17.0.16/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
java.base@17.0.16/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
app//org.apache.accumulo.core.trace.TraceWrappedRunnable.run(TraceWrappedRunnable.java:52)
java.base@17.0.16/java.lang.Thread.run(Thread.java:840)
```
--
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: notifications-unsubscr...@accumulo.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
