parent
f51301a1a6
commit
b6750cf6c2
|
@ -271,6 +271,7 @@ public class IndexFollowingIT extends CCRIntegTestCase {
|
||||||
assertMaxSeqNoOfUpdatesIsTransferred(resolveLeaderIndex("index1"), resolveFollowerIndex("index2"), numberOfShards);
|
assertMaxSeqNoOfUpdatesIsTransferred(resolveLeaderIndex("index1"), resolveFollowerIndex("index2"), numberOfShards);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/34696")
|
||||||
public void testFollowIndexAndCloseNode() throws Exception {
|
public void testFollowIndexAndCloseNode() throws Exception {
|
||||||
getFollowerCluster().ensureAtLeastNumDataNodes(3);
|
getFollowerCluster().ensureAtLeastNumDataNodes(3);
|
||||||
String leaderIndexSettings = getIndexSettings(3, 1, singletonMap(IndexSettings.INDEX_SOFT_DELETES_SETTING.getKey(), "true"));
|
String leaderIndexSettings = getIndexSettings(3, 1, singletonMap(IndexSettings.INDEX_SOFT_DELETES_SETTING.getKey(), "true"));
|
||||||
|
@ -618,6 +619,7 @@ public class IndexFollowingIT extends CCRIntegTestCase {
|
||||||
assertThat(followerClient().prepareSearch("index2").get().getHits().getTotalHits(), equalTo(2L));
|
assertThat(followerClient().prepareSearch("index2").get().getHits().getTotalHits(), equalTo(2L));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/34696")
|
||||||
public void testFailOverOnFollower() throws Exception {
|
public void testFailOverOnFollower() throws Exception {
|
||||||
int numberOfReplicas = between(1, 2);
|
int numberOfReplicas = between(1, 2);
|
||||||
getFollowerCluster().startMasterOnlyNode();
|
getFollowerCluster().startMasterOnlyNode();
|
||||||
|
|
Loading…
Reference in New Issue