ddanielr commented on code in PR #6049:
URL: https://github.com/apache/accumulo/pull/6049#discussion_r2683702124
##########
server/manager/src/main/java/org/apache/accumulo/manager/Manager.java:
##########
@@ -195,6 +195,8 @@ public class Manager extends AbstractServer implements
LiveTServerSet.Listener,
final AuditedSecurityOperation security;
final Map<TServerInstance,AtomicInteger> badServers =
Collections.synchronizedMap(new HashMap<>());
+ final Map<TServerInstance,AtomicInteger> haltedServers =
Review Comment:
Applied changes in 2a85a39
##########
server/manager/src/main/java/org/apache/accumulo/manager/Manager.java:
##########
@@ -1150,6 +1152,8 @@ private List<TabletMigration>
checkMigrationSanity(Set<TabletServerId> current,
long start = System.currentTimeMillis();
final SortedMap<TServerInstance,TabletServerStatus> result = new
ConcurrentSkipListMap<>();
final RateLimiter shutdownServerRateLimiter =
RateLimiter.create(MAX_SHUTDOWNS_PER_SEC);
+ final int maxTserverHalts =
getConfiguration().getCount(Property.MANAGER_MAX_TSERVER_HALTS);
Review Comment:
Applied changes in 2a85a39
##########
core/src/main/java/org/apache/accumulo/core/conf/Property.java:
##########
@@ -450,6 +450,10 @@ public enum Property {
"The number of threads used to run fault-tolerant executions (FATE)."
+ " These are primarily table operations like merge.",
"1.4.3"),
+ MANAGER_MAX_TSERVER_HALTS("manager.max.tservers.halts", "0",
PropertyType.COUNT,
+ "Allows the manager to force tserver halting by setting the max number
of attempted tserver halt "
+ + " requests before deleting the tserver's zlock. A value of zero
(default) disables this feature.",
+ "2.1.5"),
Review Comment:
Applied changes in 2a85a39
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
