Skip to content

Commit

Permalink
Spotless fix
Browse files Browse the repository at this point in the history
Signed-off-by: Suraj Singh <surajrider@gmail.com>
  • Loading branch information
dreamer-89 committed Jan 27, 2023
1 parent fb0b5f2 commit 2084a84
Showing 1 changed file with 6 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -31,9 +31,6 @@
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;

import static org.opensearch.test.hamcrest.OpenSearchAssertions.assertHitCount;

/**
* This test class verifies primary shard relocation with segment replication as replication strategy.
Expand Down Expand Up @@ -329,8 +326,12 @@ public void testRelocateWithQueuedOperationsDuringHandoff() throws Exception {
assertEquals(clusterHealthResponse.isTimedOut(), false);
ensureGreen(INDEX_NAME);

// Get mock transport service from newPrimary, halt recovery during segment replication (during handoff) to allow indexing in parallel.
MockTransportService mockTargetTransportService = ((MockTransportService) internalCluster().getInstance(TransportService.class, newPrimary));
// Get mock transport service from newPrimary, halt recovery during segment replication (during handoff) to allow indexing in
// parallel.
MockTransportService mockTargetTransportService = ((MockTransportService) internalCluster().getInstance(
TransportService.class,
newPrimary
));
CountDownLatch blockSegRepLatch = new CountDownLatch(1);
CountDownLatch waitForIndexingLatch = new CountDownLatch(1);
mockTargetTransportService.addSendBehavior(
Expand Down

0 comments on commit 2084a84

Please sign in to comment.