|
|
@@ -92,6 +92,7 @@ import org.elasticsearch.test.ESIntegTestCase.Scope;
|
|
|
import org.elasticsearch.test.InternalSettingsPlugin;
|
|
|
import org.elasticsearch.test.InternalTestCluster;
|
|
|
import org.elasticsearch.test.engine.MockEngineSupport;
|
|
|
+import org.elasticsearch.test.junit.annotations.TestIssueLogging;
|
|
|
import org.elasticsearch.test.store.MockFSIndexStore;
|
|
|
import org.elasticsearch.test.transport.MockTransportService;
|
|
|
import org.elasticsearch.test.transport.StubbableTransport;
|
|
|
@@ -856,6 +857,7 @@ public class IndexRecoveryIT extends ESIntegTestCase {
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ @TestIssueLogging(value = "org.elasticsearch:DEBUG", issueUrl = "https://github.com/elastic/elasticsearch/issues/45953")
|
|
|
public void testHistoryRetention() throws Exception {
|
|
|
internalCluster().startNodes(3);
|
|
|
|
|
|
@@ -907,8 +909,9 @@ public class IndexRecoveryIT extends ESIntegTestCase {
|
|
|
recoveryStates.removeIf(r -> r.getTimer().getStartNanoTime() <= desyncNanoTime);
|
|
|
|
|
|
assertThat(recoveryStates, hasSize(1));
|
|
|
- assertThat(recoveryStates.get(0).getIndex().totalFileCount(), is(0));
|
|
|
- assertThat(recoveryStates.get(0).getTranslog().recoveredOperations(), greaterThan(0));
|
|
|
+ final RecoveryState recoveryState = recoveryStates.get(0);
|
|
|
+ assertThat(recoveryState.toString(), recoveryState.getIndex().totalFileCount(), is(0));
|
|
|
+ assertThat(recoveryState.getTranslog().recoveredOperations(), greaterThan(0));
|
|
|
}
|
|
|
|
|
|
public void testDoNotInfinitelyWaitForMapping() {
|