diff --git a/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/SnapshotBasedIndexRecoveryIT.java b/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/SnapshotBasedIndexRecoveryIT.java index 8c902059a7589..561955271e57d 100644 --- a/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/SnapshotBasedIndexRecoveryIT.java +++ b/server/src/internalClusterTest/java/org/elasticsearch/indices/recovery/SnapshotBasedIndexRecoveryIT.java @@ -480,6 +480,7 @@ public void testRecoveryIsCancelledAfterDeletingTheIndex() throws Exception { .put(IndexMetadata.SETTING_NUMBER_OF_REPLICAS, 0); } createIndex(indexName, indexSettings.build()); + ensureGreen(indexName); int numDocs = randomIntBetween(300, 1000); indexDocs(indexName, numDocs, numDocs); @@ -777,6 +778,7 @@ public void testSeqNoBasedRecoveryIsUsedAfterPrimaryFailOver() throws Exception .put("index.routing.allocation.include._name", String.join(",", dataNodes)) .build() ); + ensureGreen(indexName); int numDocs = randomIntBetween(300, 1000); indexDocs(indexName, 0, numDocs); @@ -867,6 +869,8 @@ private void indexDocs(String indexName, int docIdOffset, int docCount) throws E assertThat(stats, is(notNullValue())); assertThat(stats.getSeqNoStats(), is(notNullValue())); + assertThat(stats.getSeqNoStats().getMaxSeqNo(), is(greaterThan(-1L))); + assertThat(stats.getSeqNoStats().getGlobalCheckpoint(), is(greaterThan(-1L))); assertThat(Strings.toString(stats.getSeqNoStats()), stats.getSeqNoStats().getMaxSeqNo(), equalTo(stats.getSeqNoStats().getGlobalCheckpoint())); }, 60, TimeUnit.SECONDS);