Skip to content

Commit 2d88b92

Browse files
authored
feat(failover): remove the controller limitation (#2956)
Signed-off-by: Robin Han <hanxvdovehx@gmail.com>
1 parent 7e97c27 commit 2d88b92

File tree

1 file changed

+0
-16
lines changed

1 file changed

+0
-16
lines changed

core/src/main/java/kafka/automq/failover/FailoverControlManager.java

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -265,22 +265,6 @@ private static List<FailedWal> getFailedWal(List<NodeRuntimeMetadata> allNodes)
265265
.filter(NodeRuntimeMetadata::shouldFailover)
266266
.map(DefaultFailedWal::from)
267267
.collect(Collectors.toCollection(ArrayList::new));
268-
maybeRemoveControllerNode(allNodes, result);
269268
return result;
270269
}
271-
272-
private static void maybeRemoveControllerNode(List<NodeRuntimeMetadata> allNodes, List<FailedWal> failedWALList) {
273-
long inactiveControllerCount = allNodes.stream()
274-
.filter(NodeRuntimeMetadata::isController)
275-
.filter(node -> !node.isActive())
276-
.count();
277-
if (inactiveControllerCount > 1) {
278-
LOGGER.warn("{} controller nodes is inactive, will not failover any controller node", inactiveControllerCount);
279-
Set<Integer> controllerNodeIds = allNodes.stream()
280-
.filter(NodeRuntimeMetadata::isController)
281-
.map(NodeRuntimeMetadata::id)
282-
.collect(Collectors.toSet());
283-
failedWALList.removeIf(wal -> controllerNodeIds.contains(wal.nodeId()));
284-
}
285-
}
286270
}

0 commit comments

Comments
 (0)