|
6 | 6 | * compatible open source license. |
7 | 7 | */ |
8 | 8 |
|
9 | | -package org.opensearch.search; |
| 9 | +package org.opensearch.search.pit; |
10 | 10 |
|
11 | 11 | import com.carrotsearch.hppc.cursors.ObjectCursor; |
12 | 12 | import org.junit.After; |
|
59 | 59 | * Multi node integration tests for PIT creation and search operation with PIT ID. |
60 | 60 | */ |
61 | 61 | @OpenSearchIntegTestCase.ClusterScope(scope = OpenSearchIntegTestCase.Scope.SUITE, numDataNodes = 2) |
62 | | -public class PitMultiNodeTests extends OpenSearchIntegTestCase { |
| 62 | +public class PitMultiNodeIT extends OpenSearchIntegTestCase { |
63 | 63 |
|
64 | 64 | @Before |
65 | 65 | public void setupIndex() throws ExecutionException, InterruptedException { |
@@ -244,7 +244,7 @@ public void testConcurrentCreates() throws InterruptedException { |
244 | 244 | AtomicInteger numSuccess = new AtomicInteger(); |
245 | 245 | TestThreadPool testThreadPool = null; |
246 | 246 | try { |
247 | | - testThreadPool = new TestThreadPool(DeletePitMultiNodeTests.class.getName()); |
| 247 | + testThreadPool = new TestThreadPool(PitMultiNodeIT.class.getName()); |
248 | 248 | List<Runnable> operationThreads = new ArrayList<>(); |
249 | 249 | CountDownLatch countDownLatch = new CountDownLatch(concurrentRuns); |
250 | 250 | Set<String> createSet = new HashSet<>(); |
@@ -286,7 +286,7 @@ public void testConcurrentCreatesWithDeletes() throws InterruptedException, Exec |
286 | 286 | AtomicInteger numSuccess = new AtomicInteger(); |
287 | 287 | TestThreadPool testThreadPool = null; |
288 | 288 | try { |
289 | | - testThreadPool = new TestThreadPool(PitMultiNodeTests.class.getName()); |
| 289 | + testThreadPool = new TestThreadPool(PitMultiNodeIT.class.getName()); |
290 | 290 | int concurrentRuns = randomIntBetween(20, 50); |
291 | 291 |
|
292 | 292 | List<Runnable> operationThreads = new ArrayList<>(); |
@@ -425,7 +425,7 @@ public void testConcurrentGetWithDeletes() throws InterruptedException, Executio |
425 | 425 | AtomicInteger numSuccess = new AtomicInteger(); |
426 | 426 | TestThreadPool testThreadPool = null; |
427 | 427 | try { |
428 | | - testThreadPool = new TestThreadPool(PitMultiNodeTests.class.getName()); |
| 428 | + testThreadPool = new TestThreadPool(PitMultiNodeIT.class.getName()); |
429 | 429 | int concurrentRuns = randomIntBetween(20, 50); |
430 | 430 |
|
431 | 431 | List<Runnable> operationThreads = new ArrayList<>(); |
|
0 commit comments