|
61 | 61 | * Multi node integration tests for PIT creation and search operation with PIT ID. |
62 | 62 | */ |
63 | 63 | @OpenSearchIntegTestCase.ClusterScope(scope = OpenSearchIntegTestCase.Scope.SUITE, numDataNodes = 2) |
64 | | -public class PitMultiNodeTests extends OpenSearchIntegTestCase { |
| 64 | +public class PitMultiNodeIT extends OpenSearchIntegTestCase { |
65 | 65 |
|
66 | 66 | @Before |
67 | 67 | public void setupIndex() throws ExecutionException, InterruptedException { |
@@ -246,7 +246,7 @@ public void testConcurrentCreates() throws InterruptedException { |
246 | 246 | AtomicInteger numSuccess = new AtomicInteger(); |
247 | 247 | TestThreadPool testThreadPool = null; |
248 | 248 | try { |
249 | | - testThreadPool = new TestThreadPool(DeletePitMultiNodeTests.class.getName()); |
| 249 | + testThreadPool = new TestThreadPool(PitMultiNodeIT.class.getName()); |
250 | 250 | List<Runnable> operationThreads = new ArrayList<>(); |
251 | 251 | CountDownLatch countDownLatch = new CountDownLatch(concurrentRuns); |
252 | 252 | Set<String> createSet = new HashSet<>(); |
@@ -288,7 +288,7 @@ public void testConcurrentCreatesWithDeletes() throws InterruptedException, Exec |
288 | 288 | AtomicInteger numSuccess = new AtomicInteger(); |
289 | 289 | TestThreadPool testThreadPool = null; |
290 | 290 | try { |
291 | | - testThreadPool = new TestThreadPool(PitMultiNodeTests.class.getName()); |
| 291 | + testThreadPool = new TestThreadPool(PitMultiNodeIT.class.getName()); |
292 | 292 | int concurrentRuns = randomIntBetween(20, 50); |
293 | 293 |
|
294 | 294 | List<Runnable> operationThreads = new ArrayList<>(); |
@@ -431,7 +431,7 @@ public void testConcurrentGetWithDeletes() throws InterruptedException, Executio |
431 | 431 | AtomicInteger numSuccess = new AtomicInteger(); |
432 | 432 | TestThreadPool testThreadPool = null; |
433 | 433 | try { |
434 | | - testThreadPool = new TestThreadPool(PitMultiNodeTests.class.getName()); |
| 434 | + testThreadPool = new TestThreadPool(PitMultiNodeIT.class.getName()); |
435 | 435 | int concurrentRuns = randomIntBetween(20, 50); |
436 | 436 |
|
437 | 437 | List<Runnable> operationThreads = new ArrayList<>(); |
|
0 commit comments