dlmarion commented on code in PR #6208:
URL: https://github.com/apache/accumulo/pull/6208#discussion_r2925967537
##########
test/src/main/java/org/apache/accumulo/test/MultipleManagerIT.java:
##########
@@ -197,14 +197,20 @@ public void testFate() throws Exception {
waitToSeeManagers(ctx, 3, store, false);
// Start two new manager processes and wait until 5 managers are seen
running fate operations
- managerWorkers.add(exec(FastFateCleanupManager.class));
- managerWorkers.add(exec(FastFateCleanupManager.class));
+
getCluster().getConfig().getClusterServerConfiguration().setNumManagers(5);
+ getCluster().getClusterControl().start(ServerType.MANAGER);
waitToSeeManagers(ctx, 5, store, false);
// Kill two assistant manager processes. Any fate operations that were
running should resume
// elsewhere. Should see three manager running operations after that.
- managerWorkers.get(2).destroy();
- managerWorkers.get(3).destroy();
+ var processMap = getCluster().getProcesses();
+ var processes = processMap.get(ServerType.MANAGER);
+ assertEquals(5, processes.size());
+ Iterator<ProcessReference> iter = processes.iterator();
+ iter.next();
Review Comment:
Yeah, I can make that change.
--
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]
