Skip to content

Commit

Permalink
Apply spotless
Browse files Browse the repository at this point in the history
Signed-off-by: Mohit Godwani <mgodwan@amazon.com>
  • Loading branch information
mgodwan committed Sep 3, 2024
1 parent ab0cbea commit f3e7f48
Show file tree
Hide file tree
Showing 2 changed files with 12 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -141,10 +141,7 @@ public void testPublication() throws Exception {
Settings settings = clusterService().getSettings();
logger.info("settings : {}", settings);
for (Client client : clients()) {
ClusterStateResponse response = client.admin().cluster().prepareState().clear()
.setMetadata(true)
.setLocal(true)
.get();
ClusterStateResponse response = client.admin().cluster().prepareState().clear().setMetadata(true).setLocal(true).get();

String refreshSetting = response.getState()
.metadata()
Expand All @@ -153,10 +150,8 @@ public void testPublication() throws Exception {

assertEquals("10mb", refreshSetting);


// Verify context is present in metadata
assertEquals(new Context(CONTEXT_NAME), response.getState()
.metadata().indices().get(INDEX_NAME).context());
assertEquals(new Context(CONTEXT_NAME), response.getState().metadata().indices().get(INDEX_NAME).context());
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -370,7 +370,13 @@ protected void prepareCluster(int numClusterManagerNodes, int numDataOnlyNodes,
}
}

protected void prepareClusterWithDefaultContext(int numClusterManagerNodes, int numDataOnlyNodes, String indices, int replicaCount, int shardCount) {
protected void prepareClusterWithDefaultContext(
int numClusterManagerNodes,
int numDataOnlyNodes,
String indices,
int replicaCount,
int shardCount
) {
internalCluster().startClusterManagerOnlyNodes(numClusterManagerNodes);

// Adding context template to the cluster
Expand All @@ -380,9 +386,9 @@ protected void prepareClusterWithDefaultContext(int numClusterManagerNodes, int

for (String index : indices.split(",")) {
// Ensure index is created with additional metadata field.
assertAcked(prepareCreate(index)
.setSettings(remoteStoreIndexSettings(replicaCount, shardCount))
.setContext(new Context("testcontext")));
assertAcked(
prepareCreate(index).setSettings(remoteStoreIndexSettings(replicaCount, shardCount)).setContext(new Context("testcontext"))
);

ensureYellowAndNoInitializingShards(index);
ensureGreen(index);
Expand Down

0 comments on commit f3e7f48

Please sign in to comment.