This is an automated email from the ASF dual-hosted git repository.
dlmarion pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git.
from a2f437f Add missing hadoop-mapreduce module API javadocs (#1869)
add e62ace6 Fixes #1808: refactor creation Threads/ThreadPools, set
UncaughtExceptionHandler on all threads
No new revisions were added by this update.
Summary of changes:
.../DefaultContextClassLoaderFactory.java | 31 ++--
.../core/clientImpl/ConditionalWriterImpl.java | 29 +--
.../accumulo/core/clientImpl/ScannerIterator.java | 9 +-
.../core/clientImpl/TableOperationsImpl.java | 6 +-
.../core/clientImpl/TabletServerBatchReader.java | 18 +-
.../core/clientImpl/TabletServerBatchWriter.java | 57 +++---
.../core/clientImpl/ThriftTransportPool.java | 6 +-
.../accumulo/core/clientImpl/bulk/BulkImport.java | 8 +-
.../accumulo/core/file/BloomFilterLayer.java | 13 +-
.../file/blockfile/cache/lru/LruBlockCache.java | 5 +-
.../blockfile/cache/tinylfu/TinyLfuBlockCache.java | 12 +-
.../java/org/apache/accumulo/core/util/Daemon.java | 42 -----
.../java/org/apache/accumulo/core}/util/Halt.java | 16 +-
.../accumulo/core/util/SimpleThreadPool.java | 76 --------
.../accumulo/core/util/cleaner/CleanerUtil.java | 19 ++
.../util/ratelimit/SharedRateLimiterFactory.java | 33 ++--
.../AccumuloUncaughtExceptionHandler.java | 26 ++-
.../threads/NamedRunnable.java} | 41 +++--
.../NamedThreadFactory.java} | 37 ++--
.../accumulo/core/util/threads/ThreadPools.java | 162 +++++++++++++++++
.../Threads.java} | 52 +++---
.../TracingScheduledThreadPoolExecutor.java | 95 ++++++++++
.../util/threads/TracingThreadPoolExecutor.java | 97 ++++++++++
.../main/java/org/apache/accumulo/fate/Fate.java | 21 +--
.../apache/accumulo/fate/util/LoggingRunnable.java | 72 --------
.../core/file/rfile/MultiThreadedRFileTest.java | 7 +-
.../accumulo/server/GarbageCollectionLogger.java | 2 +-
.../org/apache/accumulo/server/ServerUtil.java | 6 +-
.../accumulo/server/client/BulkImporter.java | 16 +-
.../accumulo/server/fs/VolumeManagerImpl.java | 5 +-
.../accumulo/server/master/LiveTServerSet.java | 8 +-
.../accumulo/server/problems/ProblemReports.java | 13 +-
.../apache/accumulo/server/rpc/TServerUtils.java | 123 ++++++-------
.../accumulo/server/security/SecurityUtil.java | 54 +++---
.../delegation/AuthenticationTokenKeyManager.java | 4 +-
.../accumulo/server/util/FileSystemMonitor.java | 71 ++++----
.../server/util/RemoveEntriesForMissingFiles.java | 4 +-
.../server/util/VerifyTabletAssignments.java | 4 +-
.../accumulo/server/util/time/SimpleTimer.java | 136 --------------
.../server/zookeeper/DistributedWorkQueue.java | 30 +--
.../accumulo/server/util/time/SimpleTimerTest.java | 113 ------------
.../apache/accumulo/gc/SimpleGarbageCollector.java | 14 +-
.../java/org/apache/accumulo/master/Master.java | 104 +++++------
.../org/apache/accumulo/master/MasterTime.java | 21 +--
.../apache/accumulo/master/TabletGroupWatcher.java | 6 +-
.../accumulo/master/recovery/RecoveryManager.java | 5 +-
.../master/replication/ReplicationDriver.java | 5 +-
.../accumulo/master/replication/WorkDriver.java | 8 +-
.../master/tableOps/bulkVer1/BulkImport.java | 6 +-
.../master/tableOps/bulkVer1/LoadFiles.java | 11 +-
.../master/upgrade/UpgradeCoordinator.java | 53 +++---
.../java/org/apache/accumulo/monitor/Monitor.java | 17 +-
.../org/apache/accumulo/tracer/TraceServer.java | 7 +-
.../org/apache/accumulo/tracer/ZooTraceClient.java | 5 +-
.../apache/accumulo/tserver/AssignmentHandler.java | 39 ++--
.../org/apache/accumulo/tserver/FileManager.java | 8 +-
.../org/apache/accumulo/tserver/TabletServer.java | 113 ++++++------
.../tserver/TabletServerResourceManager.java | 202 ++++++++++-----------
.../accumulo/tserver/ThriftClientHandler.java | 25 +--
.../tserver/compactions/CompactionExecutor.java | 37 ++--
.../tserver/compactions/CompactionManager.java | 4 +-
.../tserver/compactions/CompactionService.java | 12 +-
.../org/apache/accumulo/tserver/log/DfsLogger.java | 8 +-
.../org/apache/accumulo/tserver/log/LogSorter.java | 5 +-
.../accumulo/tserver/log/TabletServerLogger.java | 11 +-
.../accumulo/tserver/scan/NextBatchTask.java | 2 +-
.../accumulo/tserver/session/SessionManager.java | 12 +-
.../accumulo/tserver/tablet/CompactionWatcher.java | 6 +-
.../accumulo/tserver/AssignmentWatcherTest.java | 15 +-
.../shell/commands/ActiveCompactionHelper.java | 7 +-
.../accumulo/test/BalanceWithOfflineTableIT.java | 5 +-
.../test/functional/BatchWriterFlushIT.java | 6 +-
.../test/functional/HalfDeadTServerIT.java | 4 +-
.../accumulo/test/functional/ZombieTServer.java | 6 +-
.../accumulo/test/performance/NullTserver.java | 6 +-
75 files changed, 1128 insertions(+), 1246 deletions(-)
delete mode 100644 core/src/main/java/org/apache/accumulo/core/util/Daemon.java
rename {server/base/src/main/java/org/apache/accumulo/server =>
core/src/main/java/org/apache/accumulo/core}/util/Halt.java (87%)
delete mode 100644
core/src/main/java/org/apache/accumulo/core/util/SimpleThreadPool.java
rename core/src/main/java/org/apache/accumulo/core/util/{ =>
threads}/AccumuloUncaughtExceptionHandler.java (55%)
copy core/src/main/java/org/apache/accumulo/core/{clientImpl/Namespace.java =>
util/threads/NamedRunnable.java} (57%)
copy
core/src/main/java/org/apache/accumulo/core/util/{NamingThreadFactory.java =>
threads/NamedThreadFactory.java} (58%)
create mode 100644
core/src/main/java/org/apache/accumulo/core/util/threads/ThreadPools.java
rename
core/src/main/java/org/apache/accumulo/core/util/{NamingThreadFactory.java =>
threads/Threads.java} (53%)
create mode 100644
core/src/main/java/org/apache/accumulo/core/util/threads/TracingScheduledThreadPoolExecutor.java
create mode 100644
core/src/main/java/org/apache/accumulo/core/util/threads/TracingThreadPoolExecutor.java
delete mode 100644
core/src/main/java/org/apache/accumulo/fate/util/LoggingRunnable.java
delete mode 100644
server/base/src/main/java/org/apache/accumulo/server/util/time/SimpleTimer.java
delete mode 100644
server/base/src/test/java/org/apache/accumulo/server/util/time/SimpleTimerTest.java
