Skip to content

Commit

Permalink
Renaming tests to IT in order to not encounter rest cancellable node …
Browse files Browse the repository at this point in the history
…client handler failures

Signed-off-by: Bharathwaj G <[email protected]>
  • Loading branch information
bharath-techie committed Jan 9, 2023
1 parent 01a5842 commit 4de2db4
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 6 deletions.
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -91,6 +91,7 @@ The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
- Support OpenSSL Provider with default Netty allocator ([#5460](https://github.com/opensearch-project/OpenSearch/pull/5460))
- Increasing timeout of testQuorumRecovery to 90 seconds from 30 ([#5651](https://github.com/opensearch-project/OpenSearch/pull/5651))
- [Segment Replication] Fix for peer recovery ([#5344](https://github.com/opensearch-project/OpenSearch/pull/5344))
- [Test] Renaming PIT tests to IT to fix intermittent test failures ([#5750](https://github.com/opensearch-project/OpenSearch/pull/5750))

### Security

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,7 @@
* Multi node integration tests for delete PIT use cases
*/
@OpenSearchIntegTestCase.ClusterScope(scope = OpenSearchIntegTestCase.Scope.SUITE, numDataNodes = 2)
public class DeletePitMultiNodeTests extends OpenSearchIntegTestCase {
public class DeletePitMultiNodeIT extends OpenSearchIntegTestCase {

@Before
public void setupIndex() throws ExecutionException, InterruptedException {
Expand Down Expand Up @@ -306,7 +306,7 @@ public void testtConcurrentDeletes() throws InterruptedException, ExecutionExcep
AtomicInteger numDeleteAcknowledged = new AtomicInteger();
TestThreadPool testThreadPool = null;
try {
testThreadPool = new TestThreadPool(DeletePitMultiNodeTests.class.getName());
testThreadPool = new TestThreadPool(DeletePitMultiNodeIT.class.getName());
List<Runnable> operationThreads = new ArrayList<>();
CountDownLatch countDownLatch = new CountDownLatch(concurrentRuns);
for (int i = 0; i < concurrentRuns; i++) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -61,7 +61,7 @@
* Multi node integration tests for PIT creation and search operation with PIT ID.
*/
@OpenSearchIntegTestCase.ClusterScope(scope = OpenSearchIntegTestCase.Scope.SUITE, numDataNodes = 2)
public class PitMultiNodeTests extends OpenSearchIntegTestCase {
public class PitMultiNodeIT extends OpenSearchIntegTestCase {

@Before
public void setupIndex() throws ExecutionException, InterruptedException {
Expand Down Expand Up @@ -246,7 +246,7 @@ public void testConcurrentCreates() throws InterruptedException {
AtomicInteger numSuccess = new AtomicInteger();
TestThreadPool testThreadPool = null;
try {
testThreadPool = new TestThreadPool(DeletePitMultiNodeTests.class.getName());
testThreadPool = new TestThreadPool(PitMultiNodeIT.class.getName());
List<Runnable> operationThreads = new ArrayList<>();
CountDownLatch countDownLatch = new CountDownLatch(concurrentRuns);
Set<String> createSet = new HashSet<>();
Expand Down Expand Up @@ -288,7 +288,7 @@ public void testConcurrentCreatesWithDeletes() throws InterruptedException, Exec
AtomicInteger numSuccess = new AtomicInteger();
TestThreadPool testThreadPool = null;
try {
testThreadPool = new TestThreadPool(PitMultiNodeTests.class.getName());
testThreadPool = new TestThreadPool(PitMultiNodeIT.class.getName());
int concurrentRuns = randomIntBetween(20, 50);

List<Runnable> operationThreads = new ArrayList<>();
Expand Down Expand Up @@ -431,7 +431,7 @@ public void testConcurrentGetWithDeletes() throws InterruptedException, Executio
AtomicInteger numSuccess = new AtomicInteger();
TestThreadPool testThreadPool = null;
try {
testThreadPool = new TestThreadPool(PitMultiNodeTests.class.getName());
testThreadPool = new TestThreadPool(PitMultiNodeIT.class.getName());
int concurrentRuns = randomIntBetween(20, 50);

List<Runnable> operationThreads = new ArrayList<>();
Expand Down

0 comments on commit 4de2db4

Please sign in to comment.