This is an automated email from the ASF dual-hosted git repository.
dlmarion pushed a commit to branch elasticity
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/elasticity by this push:
new 59b873b49c Removed MAC methods deprecated in 3.1 (#4395)
59b873b49c is described below
commit 59b873b49c71649e633b95382088be6a4c94f11e
Author: Dave Marion <[email protected]>
AuthorDate: Mon Mar 18 13:18:19 2024 -0400
Removed MAC methods deprecated in 3.1 (#4395)
---
.../accumulo/minicluster/MiniAccumuloConfig.java | 35 ----------------------
.../accumulo/minicluster/MiniAccumuloRunner.java | 4 ---
2 files changed, 39 deletions(-)
diff --git
a/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloConfig.java
b/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloConfig.java
index d43008be97..6bf6739d5d 100644
---
a/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloConfig.java
+++
b/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloConfig.java
@@ -51,31 +51,6 @@ public class MiniAccumuloConfig {
this.impl = new MiniAccumuloConfigImpl(dir, rootPassword);
}
- /**
- * Calling this method is optional. If not set, it defaults to two.
- *
- * @param numTservers the number of tablet servers that mini accumulo
cluster should start
- */
- // ELASTICITY_TODO: Deprecate in 3.0.0 and remove in elasticity on the merge
- @Deprecated(since = "3.1.0")
- public MiniAccumuloConfig setNumTservers(int numTservers) {
- // impl.setNumTservers(numTservers);
- return this;
- }
-
- /**
- * Calling this method is optional. If not set, it defaults to zero.
- *
- * @param numScanServers the number of scan servers that mini accumulo
cluster should start
- * @since 2.1.0
- */
- // ELASTICITY_TODO: Deprecate in 3.0.0 and remove in elasticity on the merge
- @Deprecated(since = "3.1.0")
- public MiniAccumuloConfig setNumScanServers(int numScanServers) {
- // impl.setNumScanServers(numScanServers);
- return this;
- }
-
/**
* Calling this method is optional. If not set, defaults to 'miniInstance'
*
@@ -225,16 +200,6 @@ public class MiniAccumuloConfig {
return impl.getRootPassword();
}
- /**
- * @return the number of tservers configured for this cluster
- */
- // ELASTICITY_TODO: Deprecate in 3.0.0 and remove in elasticity on the merge
- @Deprecated(since = "3.1.0")
- public int getNumTservers() {
- return
impl.getClusterServerConfiguration().getTabletServerConfiguration().values().stream()
- .reduce(0, Integer::sum);
- }
-
/**
* @return is the current configuration in jdwpEnabled mode?
*
diff --git
a/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloRunner.java
b/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloRunner.java
index 48dcf7a337..70e8c388a9 100644
---
a/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloRunner.java
+++
b/minicluster/src/main/java/org/apache/accumulo/minicluster/MiniAccumuloRunner.java
@@ -150,7 +150,6 @@ public class MiniAccumuloRunner {
*
* @param args An optional -p argument can be specified with the path to a
valid properties file.
*/
- @SuppressWarnings("deprecation")
@SuppressFBWarnings(value = {"PATH_TRAVERSAL_IN",
"UNENCRYPTED_SERVER_SOCKET"},
justification = "code runs in same security context as user who provided
input file name; "
+ "socket need not be encrypted, since this class is provided for
testing only")
@@ -181,9 +180,6 @@ public class MiniAccumuloRunner {
if (opts.prop.containsKey(INSTANCE_NAME_PROP)) {
config.setInstanceName(opts.prop.getProperty(INSTANCE_NAME_PROP));
}
- if (opts.prop.containsKey(NUM_T_SERVERS_PROP)) {
-
config.setNumTservers(Integer.parseInt(opts.prop.getProperty(NUM_T_SERVERS_PROP)));
- }
if (opts.prop.containsKey(ZOO_KEEPER_PORT_PROP)) {
config.setZooKeeperPort(Integer.parseInt(opts.prop.getProperty(ZOO_KEEPER_PORT_PROP)));
}