This is an automated email from the ASF dual-hosted git repository.
kturner pushed a commit to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git
commit 123ce967869621d527aff453bdf43f3617bc76ec
Merge: 31323e5e5e bc932655b3
Author: Keith Turner
AuthorDate: Tue Oct 10 17:51:13 2023 -0400
Merge remote-tracking branch 'upstream/main' into elasticity
.../org/apache/accumulo/core/conf/Property.java| 6 +-
.../accumulo/core/metadata/StoredTabletFile.java | 8 +
.../util/compaction/ExternalCompactionUtil.java| 16 +-
pom.xml| 49 ---
.../constraints/MetadataConstraintsTest.java | 210 +++---
server/compactor/pom.xml | 38 +-
.../apache/accumulo/compactor/CompactorTest.java | 455 -
.../src/test/resources/log4j2-test.properties | 35 --
server/native/pom.xml | 5 -
src/build/ci/find-unapproved-junit.sh | 8 +-
start/pom.xml | 17 +-
.../accumulo/test/functional/MonitorSslIT.java | 2 +-
.../accumulo/test/functional/ReadWriteIT.java | 2 +-
.../org/apache/accumulo/test/shell/MockShell.java | 17 +-
.../apache/accumulo/test/shell/ShellServerIT.java | 68 +--
15 files changed, 250 insertions(+), 686 deletions(-)
diff --cc
core/src/main/java/org/apache/accumulo/core/util/compaction/ExternalCompactionUtil.java
index e4eda5713d,cbda041d41..697f079d40
---
a/core/src/main/java/org/apache/accumulo/core/util/compaction/ExternalCompactionUtil.java
+++
b/core/src/main/java/org/apache/accumulo/core/util/compaction/ExternalCompactionUtil.java
@@@ -99,15 -99,9 +99,9 @@@ public class ExternalCompactionUtil
* @return Optional HostAndPort of Coordinator node if found
*/
public static Optional findCompactionCoordinator(ClientContext
context) {
-final String lockPath = context.getZooKeeperRoot() +
Constants.ZCOORDINATOR_LOCK;
+final String lockPath = context.getZooKeeperRoot() +
Constants.ZMANAGER_LOCK;
- try {
- var zk = ZooSession.getAnonymousSession(context.getZooKeepers(),
- context.getZooKeepersSessionTimeOut());
- return ServiceLock.getLockData(zk, ServiceLock.path(lockPath))
- .map(sld -> sld.getAddress(ThriftService.COORDINATOR));
- } catch (KeeperException | InterruptedException e) {
- throw new IllegalStateException(e);
- }
+ return ServiceLock.getLockData(context.getZooCache(),
ServiceLock.path(lockPath), new ZcStat())
+ .map(sld -> sld.getAddress(ThriftService.COORDINATOR));
}
/**
@@@ -115,14 -109,14 +109,14 @@@
*/
public static Map> getCompactorAddrs(ClientContext
context) {
try {
- final Map> queuesAndAddresses = new
HashMap<>();
- final String compactorQueuesPath = context.getZooKeeperRoot() +
Constants.ZCOMPACTORS;
+ final Map> groupsAndAddresses = new
HashMap<>();
+ final String compactorGroupsPath = context.getZooKeeperRoot() +
Constants.ZCOMPACTORS;
ZooReader zooReader = context.getZooReader();
- List queues = zooReader.getChildren(compactorQueuesPath);
- for (String queue : queues) {
-queuesAndAddresses.putIfAbsent(queue, new ArrayList<>());
+ List groups = zooReader.getChildren(compactorGroupsPath);
+ for (String group : groups) {
- groupsAndAddresses.putIfAbsent(group, new ArrayList());
++groupsAndAddresses.putIfAbsent(group, new ArrayList<>());
try {
- List compactors = zooReader.getChildren(compactorQueuesPath
+ "/" + queue);
+ List compactors = zooReader.getChildren(compactorGroupsPath
+ "/" + group);
for (String compactor : compactors) {
// compactor is the address, we are checking to see if there is a
child node which
// represents the compactor's lock as a check that it's alive.
diff --cc pom.xml
index 7a5a7f1fde,602809f869..4fd8a15edd
--- a/pom.xml
+++ b/pom.xml
@@@ -322,12 -322,11 +321,6 @@@
commons-logging
1.2
--
-
- junit
- junit
- 4.13.2
-org.apache.accumulo
-accumulo-compaction-coordinator
-${project.version}
--
org.apache.accumulo
accumulo-compactor
@@@ -623,37 -622,6 +616,11 @@@
-
-
- org.objenesis
- objenesis
- 3.3
-
+
+org.opentest4j
+opentest4j
+1.2.0
+
-
- org.powermock
- powermock-api-easymock
- ${version.powermock}
-
-
- org.powermock
- powermock-core
- ${version.powermock}
-
-
- org.powermock
- powermock-module-junit4
- ${version.powermock}
-
-
- org.powermock
- powermock-refl