|
|
@@ -1215,9 +1215,15 @@ public class CoordinatorTests extends AbstractCoordinatorTestCase {
|
|
|
clusterNode.disconnect();
|
|
|
}
|
|
|
|
|
|
- cluster.runFor(defaultMillis(LEADER_CHECK_INTERVAL_SETTING) + defaultMillis(LEADER_CHECK_TIMEOUT_SETTING),
|
|
|
+ cluster.runFor(defaultMillis(LEADER_CHECK_TIMEOUT_SETTING) // to wait for any in-flight check to time out
|
|
|
+ + defaultMillis(LEADER_CHECK_INTERVAL_SETTING) // to wait for the next check to be sent
|
|
|
+ + 2 * DEFAULT_DELAY_VARIABILITY, // to send the failing check and receive the disconnection response
|
|
|
"waiting for leader failure");
|
|
|
|
|
|
+ for (final ClusterNode clusterNode : cluster.clusterNodes) {
|
|
|
+ assertThat(clusterNode.getId() + " is CANDIDATE", clusterNode.coordinator.getMode(), is(CANDIDATE));
|
|
|
+ }
|
|
|
+
|
|
|
for (int i = scaledRandomIntBetween(1, 10); i >= 0; i--) {
|
|
|
final MockLogAppender mockLogAppender = new MockLogAppender();
|
|
|
try {
|