|
@@ -1089,6 +1089,7 @@ public class AbstractCoordinatorTestCase extends ESTestCase {
|
|
persistedState,
|
|
persistedState,
|
|
() -> disconnectedNodes.contains(localNode.getId())
|
|
() -> disconnectedNodes.contains(localNode.getId())
|
|
|| blackholedNodes.contains(localNode.getId())
|
|
|| blackholedNodes.contains(localNode.getId())
|
|
|
|
+ || nodeHealthService.getHealth().getStatus() != HEALTHY
|
|
|| (disruptStorage && rarely())
|
|
|| (disruptStorage && rarely())
|
|
);
|
|
);
|
|
coordinator = new Coordinator(
|
|
coordinator = new Coordinator(
|