109
109
import java .util .stream .Collectors ;
110
110
import java .util .stream .LongStream ;
111
111
112
- import static com .carrotsearch .randomizedtesting .RandomizedTest .randomLongBetween ;
113
112
import static org .elasticsearch .common .util .BigArrays .NON_RECYCLING_INSTANCE ;
114
113
import static org .elasticsearch .index .translog .SnapshotMatchers .containsOperationsInAnyOrder ;
115
114
import static org .elasticsearch .index .translog .TranslogDeletionPolicies .createTranslogDeletionPolicy ;
@@ -2225,6 +2224,7 @@ public void testWithRandomException() throws IOException {
2225
2224
unsynced .clear ();
2226
2225
failableTLog .rollGeneration ();
2227
2226
committing = true ;
2227
+ failableTLog .getDeletionPolicy ().setTranslogGenerationOfLastCommit (failableTLog .currentFileGeneration ());
2228
2228
failableTLog .getDeletionPolicy ().setMinTranslogGenerationForRecovery (failableTLog .currentFileGeneration ());
2229
2229
failableTLog .trimUnreferencedReaders ();
2230
2230
committing = false ;
@@ -2267,6 +2267,7 @@ public void testWithRandomException() throws IOException {
2267
2267
if (randomBoolean ()) {
2268
2268
try {
2269
2269
TranslogDeletionPolicy deletionPolicy = createTranslogDeletionPolicy ();
2270
+ deletionPolicy .setTranslogGenerationOfLastCommit (minGenForRecovery );
2270
2271
deletionPolicy .setMinTranslogGenerationForRecovery (minGenForRecovery );
2271
2272
IOUtils .close (getFailableTranslog (fail , config , randomBoolean (), false , generationUUID , deletionPolicy ));
2272
2273
} catch (TranslogException | MockDirectoryWrapper .FakeIOException ex ) {
@@ -2278,6 +2279,7 @@ public void testWithRandomException() throws IOException {
2278
2279
2279
2280
fail .failNever (); // we don't wanna fail here but we might since we write a new checkpoint and create a new tlog file
2280
2281
TranslogDeletionPolicy deletionPolicy = createTranslogDeletionPolicy ();
2282
+ deletionPolicy .setTranslogGenerationOfLastCommit (minGenForRecovery );
2281
2283
deletionPolicy .setMinTranslogGenerationForRecovery (minGenForRecovery );
2282
2284
try (Translog translog = new Translog (config , generationUUID , deletionPolicy , () -> SequenceNumbers .UNASSIGNED_SEQ_NO );
2283
2285
Translog .Snapshot snapshot = translog .newSnapshotFromGen (minGenForRecovery )) {
0 commit comments