|
19 | 19 |
|
20 | 20 | package org.elasticsearch.index.engine; |
21 | 21 |
|
| 22 | +import java.io.IOException; |
| 23 | +import java.io.UncheckedIOException; |
| 24 | +import java.nio.charset.Charset; |
| 25 | +import java.nio.file.Files; |
| 26 | +import java.nio.file.Path; |
| 27 | +import java.util.ArrayList; |
| 28 | +import java.util.Arrays; |
| 29 | +import java.util.Base64; |
| 30 | +import java.util.Collections; |
| 31 | +import java.util.Comparator; |
| 32 | +import java.util.HashSet; |
| 33 | +import java.util.Iterator; |
| 34 | +import java.util.LinkedHashMap; |
| 35 | +import java.util.List; |
| 36 | +import java.util.Map; |
| 37 | +import java.util.Queue; |
| 38 | +import java.util.Set; |
| 39 | +import java.util.concurrent.BrokenBarrierException; |
| 40 | +import java.util.concurrent.CountDownLatch; |
| 41 | +import java.util.concurrent.CyclicBarrier; |
| 42 | +import java.util.concurrent.TimeUnit; |
| 43 | +import java.util.concurrent.atomic.AtomicBoolean; |
| 44 | +import java.util.concurrent.atomic.AtomicInteger; |
| 45 | +import java.util.concurrent.atomic.AtomicLong; |
| 46 | +import java.util.concurrent.atomic.AtomicReference; |
| 47 | +import java.util.function.BiFunction; |
| 48 | +import java.util.function.Function; |
| 49 | +import java.util.function.LongSupplier; |
| 50 | +import java.util.function.Supplier; |
| 51 | +import java.util.function.ToLongBiFunction; |
| 52 | +import java.util.stream.Collectors; |
| 53 | +import java.util.stream.LongStream; |
| 54 | + |
22 | 55 | import com.carrotsearch.hppc.cursors.ObjectObjectCursor; |
23 | 56 | import com.carrotsearch.randomizedtesting.generators.RandomNumbers; |
24 | 57 | import org.apache.logging.log4j.Level; |
|
123 | 156 | import org.hamcrest.MatcherAssert; |
124 | 157 | import org.hamcrest.Matchers; |
125 | 158 |
|
126 | | -import java.io.IOException; |
127 | | -import java.io.UncheckedIOException; |
128 | | -import java.nio.charset.Charset; |
129 | | -import java.nio.file.Files; |
130 | | -import java.nio.file.Path; |
131 | | -import java.util.ArrayList; |
132 | | -import java.util.Arrays; |
133 | | -import java.util.Base64; |
134 | | -import java.util.Collections; |
135 | | -import java.util.Comparator; |
136 | | -import java.util.HashSet; |
137 | | -import java.util.Iterator; |
138 | | -import java.util.LinkedHashMap; |
139 | | -import java.util.List; |
140 | | -import java.util.Map; |
141 | | -import java.util.Queue; |
142 | | -import java.util.Set; |
143 | | -import java.util.concurrent.BrokenBarrierException; |
144 | | -import java.util.concurrent.CountDownLatch; |
145 | | -import java.util.concurrent.CyclicBarrier; |
146 | | -import java.util.concurrent.TimeUnit; |
147 | | -import java.util.concurrent.atomic.AtomicBoolean; |
148 | | -import java.util.concurrent.atomic.AtomicInteger; |
149 | | -import java.util.concurrent.atomic.AtomicLong; |
150 | | -import java.util.concurrent.atomic.AtomicReference; |
151 | | -import java.util.function.BiFunction; |
152 | | -import java.util.function.Function; |
153 | | -import java.util.function.LongSupplier; |
154 | | -import java.util.function.Supplier; |
155 | | -import java.util.function.ToLongBiFunction; |
156 | | -import java.util.stream.Collectors; |
157 | | -import java.util.stream.LongStream; |
158 | | - |
159 | 159 | import static java.util.Collections.emptyMap; |
160 | 160 | import static java.util.Collections.shuffle; |
161 | 161 | import static org.elasticsearch.index.engine.Engine.Operation.Origin.LOCAL_TRANSLOG_RECOVERY; |
@@ -2050,6 +2050,7 @@ public void testIndexWriterInfoStream() throws IllegalAccessException, IOExcepti |
2050 | 2050 | } |
2051 | 2051 | } |
2052 | 2052 |
|
| 2053 | + @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/32430") |
2053 | 2054 | public void testSeqNoAndCheckpoints() throws IOException { |
2054 | 2055 | final int opCount = randomIntBetween(1, 256); |
2055 | 2056 | long primarySeqNo = SequenceNumbers.NO_OPS_PERFORMED; |
|
0 commit comments