This is an automated email from the ASF dual-hosted git repository.
edcoleman pushed a commit to branch 2.1
in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/2.1 by this push:
new d3f8a8b2b5 fixes minor qualtity check issues (#4351)
d3f8a8b2b5 is described below
commit d3f8a8b2b587bed44c978fc6b742e7bfe286148f
Author: EdColeman <[email protected]>
AuthorDate: Fri Mar 8 13:09:02 2024 -0500
fixes minor qualtity check issues (#4351)
---
.../src/main/java/org/apache/accumulo/manager/Manager.java | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
diff --git
a/server/manager/src/main/java/org/apache/accumulo/manager/Manager.java
b/server/manager/src/main/java/org/apache/accumulo/manager/Manager.java
index 9d71e542f9..1b63f18381 100644
--- a/server/manager/src/main/java/org/apache/accumulo/manager/Manager.java
+++ b/server/manager/src/main/java/org/apache/accumulo/manager/Manager.java
@@ -595,7 +595,6 @@ public class Manager extends AbstractServer
}
return TabletGoalState.UNASSIGNED;
case UNLOAD_ROOT_TABLET:
- return TabletGoalState.UNASSIGNED;
case STOP:
return TabletGoalState.UNASSIGNED;
default:
@@ -766,7 +765,7 @@ public class Manager extends AbstractServer
public void run() {
EventCoordinator.Listener eventListener = nextEvent.getListener();
while (stillManager()) {
- long wait = DEFAULT_WAIT_FOR_WATCHER;
+ long wait;
try {
switch (getManagerGoalState()) {
case NORMAL:
@@ -1497,7 +1496,7 @@ public class Manager extends AbstractServer
}
if (acquiredLock) {
- Halt.halt("Zoolock in unexpected state FAL " + acquiredLock + " " +
failedToAcquireLock,
+ Halt.halt("Zoolock in unexpected state acquiredLock true with FAL " +
failedToAcquireLock,
-1);
}
@@ -1509,7 +1508,9 @@ public class Manager extends AbstractServer
while (!acquiredLock && !failedToAcquireLock) {
try {
wait();
- } catch (InterruptedException e) {}
+ } catch (InterruptedException e) {
+ // empty
+ }
}
}
}
@@ -1655,7 +1656,7 @@ public class Manager extends AbstractServer
for (TableId tableId : context.getTableIdToNameMap().keySet()) {
TableState state = manager.getTableState(tableId);
- if ((state != null) && (state == TableState.ONLINE)) {
+ if (state == TableState.ONLINE) {
result.add(tableId);
}
}