This is an automated email from the ASF dual-hosted git repository.
cshannon pushed a change to branch grpc
in repository https://gitbox.apache.org/repos/asf/accumulo.git
from ea48421dbe Merge branch 'main' into elasticity
add e16d51b457 Backport IdleProcessMetricsIT from #4764
add 5dbaec8f78 Merge branch '2.1'
add 800eecf390 Merge branch 'main' into elasticity
add 8b879c4e7a Bump the copyright year to 2024
add 70621e16b6 Merge branch '2.1'
add 083590c4e3 Merge branch 'main' into elasticity
add 12c6433acb tests log recovery using FlakyAmple (#4762)
add 789f31210e tests ondemand tablet unload using FlakyAmple (#4769)
add ab8e0e3b73 Add metrics for User fate transactions (#4771)
add 684c514469 tests user compaction requested using FlakyAmple (#4772)
add 00da7799ae Collapse MutableByteSequence into ArrayByteSequence (#4745)
add 24ead4b4bd Merge branch 'main' into elasticity
add 99af30f283 Add Balancer Metric for Migrations Needed (#4699)
add 2cab146529 Merge branch '2.1'
add d4249cfb18 Merge branch 'main' into elasticity
add ec2f1bd881 Improves accumulo-cluster for start and stop commands
(#4763)
add 1b458ff53b Merge branch '2.1'
add 11b1f48f03 Fix property override commands in accumulo-cluster
add 102a9744bb Merge branch 'main' into elasticity
add edf829d419 Change variable reference in log message
add b90ca95323 Adds constants for threadPool Names (#4768)
add 9ec22b4b03 Merge branch '2.1'
add 7b3eeb9444 Merge branch 'main' into elasticity
add e4e8613e6d Fix issue when SERVICE_INSTANCE is empty string (#4773)
add 95a6ca23ad Merge branch '2.1'
add f106e10153 Merge branch 'main' into elasticity
add fffed51104 Verify upgrade is complete before starting fate (#3717)
add 63dd6503ad Merge branch '2.1'
add 8f92187c59 Merge branch 'main' into elasticity
add bdb8ce9725 Add fine-grained options to GrepIterator
add a6e1fd2ce6 Merge branch '2.1'
add 0ce1960d7a Merge branch 'main' into elasticity
add 7cf5c73222 Modified coordinator restart test to test compaction
duration update (#4766)
add 0ab8c80768 Fix failing test (#4776)
add a3dfcae9ca Merge branch 'main' into elasticity
add cbcf0a0568 Modifications to make compaction queue size dynamic (#4767)
add c1b1781f0e test volume replacement with flaky ample (#4781)
add fc4bc695fd Add getData methods to Key that populate ArrayByteSequence
(#4779)
add d2ea53d3cf Merge branch 'main' into elasticity
add 41fd482771 Replace OpTimer with new Timer class (#4784)
add 3e6c5be1b8 Merge remote-tracking branch 'upstream/2.1'
add d73ecd841c Merge remote-tracking branch 'upstream/main' into elasticity
add 61efda6b59 Correct zk mutability in docs for TSERV_SESSION_MAXIDLE and
TSERV_UPDATE_SESSION_MAXIDLE (#4780)
add a687ddf6a3 Merge remote-tracking branch 'upstream/2.1'
add 47c217c0c0 Merge remote-tracking branch 'upstream/main' into elasticity
add e910adc56c Fixed TimerTest elapsed duration checks (#4788)
add 092dacf5d0 Merge branch '2.1'
add f5b08c60b4 Merge branch 'main' into elasticity
add 621ad51be1 adds javadoc and tests to GrepIterator (#4775)
add ea1558e4b7 improves VisibilityFilterTest (#4778)
add 1e75ed1154 Merge branch '2.1'
add d1456fcaa4 Merge branch 'main' into elasticity
No new revisions were added by this update.
Summary of changes:
NOTICE | 2 +-
assemble/bin/accumulo-cluster | 209 +++++++++++--
assemble/bin/accumulo-service | 140 +++++++--
assemble/src/main/resources/NOTICE | 2 +-
.../accumulo/core/clientImpl/ClientContext.java | 25 +-
.../core/clientImpl/ClientTabletCacheImpl.java | 25 +-
.../core/clientImpl/ConditionalWriterImpl.java | 3 +-
.../core/clientImpl/InstanceOperationsImpl.java | 3 +-
.../core/clientImpl/NamespaceOperationsImpl.java | 18 +-
.../core/clientImpl/RootClientTabletCache.java | 10 +-
.../core/clientImpl/TableOperationsImpl.java | 22 +-
.../core/clientImpl/TabletServerBatchReader.java | 8 +-
.../TabletServerBatchReaderIterator.java | 15 +-
.../core/clientImpl/TabletServerBatchWriter.java | 8 +-
.../accumulo/core/clientImpl/ThriftScanner.java | 28 +-
.../accumulo/core/clientImpl/bulk/BulkImport.java | 12 +-
.../org/apache/accumulo/core/conf/Property.java | 17 +-
.../core/conf/cluster/ClusterConfigParser.java | 23 +-
.../accumulo/core/data/ArrayByteSequence.java | 20 +-
.../java/org/apache/accumulo/core/data/Key.java | 54 +++-
.../accumulo/core/file/BloomFilterLayer.java | 3 +-
.../org/apache/accumulo/core/file/rfile/RFile.java | 7 +-
.../accumulo/core/file/rfile/RelativeKey.java | 84 +++---
.../accumulo/core/iterators/user/GrepIterator.java | 105 ++++++-
.../metadata/MetadataCachedTabletObtainer.java | 12 +-
.../accumulo/core/metrics/MetricsProducer.java | 10 +
.../accumulo/core/util/LocalityGroupUtil.java | 6 +-
.../accumulo/core/util/MutableByteSequence.java | 47 ---
.../org/apache/accumulo/core/util/OpTimer.java | 131 --------
.../java/org/apache/accumulo/core/util/Timer.java | 91 ++++++
.../util/compaction/ExternalCompactionUtil.java | 7 +-
.../core/util/threads/ThreadPoolNames.java | 71 +++++
.../accumulo/core/util/threads/ThreadPools.java | 60 +++-
.../core/conf/cluster/ClusterConfigParserTest.java | 26 +-
.../accumulo/core/data/ArrayByteSequenceTest.java | 18 +-
.../core/file/rfile/MultiThreadedRFileTest.java | 2 +-
.../accumulo/core/file/rfile/RelativeKeyTest.java | 9 +-
.../iterators/system/VisibilityFilterTest.java | 104 ++++++-
.../core/iterators/user/GrepIteratorTest.java | 140 +++++++++
.../org/apache/accumulo/core/util/OpTimerTest.java | 168 -----------
.../org/apache/accumulo/core/util/TimerTest.java | 99 +++++++
.../threads/ThreadPoolExecutorBuilderTest.java | 14 +-
.../cluster/cluster-with-optional-services.yaml | 9 +-
.../miniclusterImpl/MiniAccumuloConfigImpl.java | 4 +-
.../conf/store/impl/PropCacheCaffeineImpl.java | 4 +-
.../server/conf/store/impl/PropStoreWatcher.java | 2 +-
.../accumulo/server/metrics/MetricsInfoImpl.java | 7 +-
.../accumulo/server/problems/ProblemReports.java | 2 +-
.../apache/accumulo/server/rpc/TServerUtils.java | 12 +-
.../server/util/RemoveEntriesForMissingFiles.java | 6 +-
.../server/util/VerifyTabletAssignments.java | 6 +-
.../server/conf/store/impl/ReadyMonitorTest.java | 2 +-
.../java/org/apache/accumulo/manager/Manager.java | 96 +++---
.../accumulo/manager/TabletGroupWatcher.java | 23 +-
.../coordinator/CompactionCoordinator.java | 59 ++--
.../queue/CompactionJobPriorityQueue.java | 20 +-
.../accumulo/manager/metrics/BalancerMetrics.java} | 32 +-
.../accumulo/manager/metrics/ManagerMetrics.java | 15 +-
.../manager/metrics/fate/FateMetricValues.java | 180 ++++-------
.../accumulo/manager/metrics/fate/FateMetrics.java | 103 ++++---
.../metrics/fate/meta/MetaFateMetricValues.java | 144 +++++++++
.../manager/metrics/fate/meta/MetaFateMetrics.java | 81 +++++
.../metrics/fate/user/UserFateMetricValues.java | 63 ++++
.../metrics/fate/user/UserFateMetrics.java} | 32 +-
.../manager/tableOps/bulkVer2/BulkImportMove.java | 4 +-
.../tableOps/tableImport/MoveExportedFiles.java | 4 +-
.../manager/upgrade/UpgradeCoordinator.java | 6 +-
.../compaction/CompactionCoordinatorTest.java | 2 +-
.../queue/CompactionJobPriorityQueueTest.java | 9 +
.../MetaFateMetricValuesTest.java} | 10 +-
server/native/src/main/resources/NOTICE | 2 +-
.../org/apache/accumulo/tserver/ScanServer.java | 5 +-
.../tserver/TabletServerResourceManager.java | 43 ++-
.../org/apache/accumulo/tserver/log/LogSorter.java | 3 +-
.../accumulo/tserver/log/TabletServerLogger.java | 3 +-
.../accumulo/shell/commands/GrepCommand.java | 6 +-
.../java/org/apache/accumulo/test/BalanceIT.java | 14 +
.../accumulo/test/BalanceWithOfflineTableIT.java | 4 +-
.../accumulo/test/ScanServerMetadataEntriesIT.java | 68 +++--
.../apache/accumulo/test/VolumeFlakyAmpleIT.java | 53 ++++
.../java/org/apache/accumulo/test/VolumeIT.java | 329 +--------------------
.../test/{VolumeIT.java => VolumeITBase.java} | 256 +++-------------
.../test/ample/FlakyAmpleServerContext.java | 16 +-
.../CompactionPriorityQueueMetricsIT.java | 2 +-
.../test/compaction/ExternalCompaction_3_IT.java | 115 ++++---
.../BalanceInPresenceOfOfflineTableIT.java | 2 +
.../test/functional/BatchWriterFlushIT.java | 2 +-
.../accumulo/test/functional/CompactionBaseIT.java | 189 ++++++++++++
...lakyFateIT.java => CompactionFlakyAmpleIT.java} | 13 +-
.../accumulo/test/functional/CompactionIT.java | 144 +--------
.../OnDemandTabletUnloadingFlakyAmpleIT.java | 92 ++++++
...{MergeFlakyFateIT.java => WALFlakyAmpleIT.java} | 16 +-
.../{WALSunnyDayIT.java => WALSunnyDayBaseIT.java} | 5 +-
.../accumulo/test/functional/WALSunnyDayIT.java | 269 +----------------
.../apache/accumulo/test/metrics/MetricsIT.java | 32 +-
95 files changed, 2430 insertions(+), 2048 deletions(-)
delete mode 100644
core/src/main/java/org/apache/accumulo/core/util/MutableByteSequence.java
delete mode 100644
core/src/main/java/org/apache/accumulo/core/util/OpTimer.java
create mode 100644 core/src/main/java/org/apache/accumulo/core/util/Timer.java
create mode 100644
core/src/main/java/org/apache/accumulo/core/util/threads/ThreadPoolNames.java
delete mode 100644
core/src/test/java/org/apache/accumulo/core/util/OpTimerTest.java
create mode 100644
core/src/test/java/org/apache/accumulo/core/util/TimerTest.java
copy
server/{base/src/main/java/org/apache/accumulo/server/metrics/ThriftMetrics.java
=>
manager/src/main/java/org/apache/accumulo/manager/metrics/BalancerMetrics.java}
(58%)
create mode 100644
server/manager/src/main/java/org/apache/accumulo/manager/metrics/fate/meta/MetaFateMetricValues.java
create mode 100644
server/manager/src/main/java/org/apache/accumulo/manager/metrics/fate/meta/MetaFateMetrics.java
create mode 100644
server/manager/src/main/java/org/apache/accumulo/manager/metrics/fate/user/UserFateMetricValues.java
copy
server/{base/src/main/java/org/apache/accumulo/server/conf/CheckServerConfig.java
=>
manager/src/main/java/org/apache/accumulo/manager/metrics/fate/user/UserFateMetrics.java}
(57%)
rename
server/manager/src/test/java/org/apache/accumulo/manager/metrics/fate/{FateMetricValuesTest.java
=> meta/MetaFateMetricValuesTest.java} (83%)
create mode 100644
test/src/main/java/org/apache/accumulo/test/VolumeFlakyAmpleIT.java
copy test/src/main/java/org/apache/accumulo/test/{VolumeIT.java =>
VolumeITBase.java} (61%)
create mode 100644
test/src/main/java/org/apache/accumulo/test/functional/CompactionBaseIT.java
copy
test/src/main/java/org/apache/accumulo/test/functional/{DeleteRowsFlakyFateIT.java
=> CompactionFlakyAmpleIT.java} (75%)
create mode 100644
test/src/main/java/org/apache/accumulo/test/functional/OnDemandTabletUnloadingFlakyAmpleIT.java
copy
test/src/main/java/org/apache/accumulo/test/functional/{MergeFlakyFateIT.java
=> WALFlakyAmpleIT.java} (70%)
copy
test/src/main/java/org/apache/accumulo/test/functional/{WALSunnyDayIT.java =>
WALSunnyDayBaseIT.java} (98%)
