Skip to content

Commit

Permalink
fixed style issues
Browse files Browse the repository at this point in the history
Signed-off-by: Vinay Krishna Pudyodu <[email protected]>
  • Loading branch information
vinaykpud committed Nov 25, 2024
1 parent fcdcdda commit d3a8a89
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -168,7 +168,6 @@ protected SegmentReplicationShardStatsResponse shardOperation(SegmentReplication
ShardId shardId = shardRouting.shardId();
IndexShard indexShard = indicesService.indexServiceSafe(shardId.getIndex()).getShard(shardId.id());

System.out.println(indexShard.indexSettings().isSegRepEnabledOrRemoteNode());
if (indexShard.indexSettings().isSegRepEnabledOrRemoteNode() == false) {
return null;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -8,9 +8,6 @@

package org.opensearch.action.admin.indices.replication;

import org.junit.Before;
import org.mockito.Mock;
import org.mockito.MockitoAnnotations;
import org.opensearch.Version;
import org.opensearch.action.support.ActionFilters;
import org.opensearch.cluster.ClusterState;
Expand Down Expand Up @@ -45,6 +42,7 @@
import org.opensearch.indices.replication.common.ReplicationType;
import org.opensearch.test.OpenSearchTestCase;
import org.opensearch.transport.TransportService;
import org.junit.Before;

import java.util.ArrayList;
import java.util.EnumSet;
Expand All @@ -53,6 +51,9 @@
import java.util.Map;
import java.util.Set;

import org.mockito.Mock;
import org.mockito.MockitoAnnotations;

import static org.mockito.ArgumentMatchers.any;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.verify;
Expand Down Expand Up @@ -526,7 +527,7 @@ public void testNewResponseWhenTwoPrimaryShardsForSameIndex() {
public void testNewResponseWhenShardsToFetchEmptyAndResponsesContainsNull() {
SegmentReplicationStatsRequest request = new SegmentReplicationStatsRequest();
List<DefaultShardOperationFailedException> shardFailures = new ArrayList<>();
String[] shards = { };
String[] shards = {};
request.shards(shards);

int totalShards = 3;
Expand Down Expand Up @@ -596,7 +597,6 @@ public void testNewResponseWhenShardsToFetchEmptyAndResponsesContainsNull() {
}
}


public void testShardOperationWithSegRepDisabled() {
ShardRouting shardRouting = mock(ShardRouting.class);
ShardId shardId = new ShardId(new Index("test-index", "test-uuid"), 0);
Expand Down

0 comments on commit d3a8a89

Please sign in to comment.