Skip to content

Commit

Permalink
Spotless fix
Browse files Browse the repository at this point in the history
Signed-off-by: Suraj Singh <[email protected]>
  • Loading branch information
dreamer-89 committed May 11, 2023
1 parent effdbd9 commit 29693b2
Showing 1 changed file with 2 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -42,7 +42,6 @@
import org.opensearch.client.ResponseException;
import org.opensearch.client.RestClient;
import org.opensearch.cluster.metadata.IndexMetadata;
import org.opensearch.cluster.routing.allocation.allocator.BalancedShardsAllocator;
import org.opensearch.common.Strings;
import org.opensearch.common.settings.Settings;
import org.opensearch.common.xcontent.json.JsonXContent;
Expand All @@ -67,7 +66,6 @@

public class IndexingIT extends OpenSearchRestTestCase {


private int indexDocs(String index, final int idStart, final int numDocs) throws IOException {
for (int i = 0; i < numDocs; i++) {
final int id = idStart + i;
Expand Down Expand Up @@ -138,7 +136,7 @@ public void testIndexingWithPrimaryOnBwcNodes() throws Exception {
ensureYellow(index);
printIndexSettings(index);

int docCount = 20;
int docCount = 200;
try (RestClient nodeClient = buildClient(restClientSettings(),
nodes.getNewNodes().stream().map(Node::getPublishAddress).toArray(HttpHost[]::new))) {

Expand Down Expand Up @@ -507,11 +505,10 @@ private void assertSeqNoOnShards(String index, Nodes nodes, int numDocs, RestCli
});
}

private List<Shard> buildShards(String index, Nodes nodes, RestClient client) throws IOException, ParseException {
private List<Shard> buildShards(String index, Nodes nodes, RestClient client) throws IOException {
Request request = new Request("GET", index + "/_stats");
request.addParameter("level", "shards");
Response response = client.performRequest(request);
logger.info("_stats response --> {}", EntityUtils.toString(client().performRequest(request).getEntity()).trim());
List<Object> shardStats = ObjectPath.createFromResponse(response).evaluate("indices." + index + ".shards.0");
ArrayList<Shard> shards = new ArrayList<>();
for (Object shard : shardStats) {
Expand Down

0 comments on commit 29693b2

Please sign in to comment.