Increase logging testRetentionPolicyChangeDuringRecovery
Relates
@@ -43,6 +43,7 @@ import org.elasticsearch.index.seqno.SequenceNumbers;
import org.elasticsearch.index.shard.IndexShard;
import org.elasticsearch.index.translog.SnapshotMatchers;
import org.elasticsearch.index.translog.Translog;
+import org.elasticsearch.test.junit.annotations.TestLogging;
import java.util.HashMap;
import java.util.List;
@@ -73,6 +74,7 @@ public class RecoveryTests extends ESIndexLevelReplicationTestCase {
}
}
+ @TestLogging("_root:TRACE")
public void testRetentionPolicyChangeDuringRecovery() throws Exception {
try (ReplicationGroup shards = createGroup(0)) {
shards.startPrimary();
@@ -99,7 +101,10 @@ public class RecoveryTests extends ESIndexLevelReplicationTestCase {
releaseRecovery.countDown();
future.get();
// rolling/flushing is async
- assertBusy(() -> assertThat(replica.estimateTranslogOperationsFromMinSeq(0), equalTo(0)));
+ assertBusy(() -> {
+ assertThat(replica.getLastSyncedGlobalCheckpoint(), equalTo(19L));
+ assertThat(replica.estimateTranslogOperationsFromMinSeq(0), equalTo(0));
+ });
}
}
