Skip to content

Commit 27d1f61

Browse files
committed
Fix formatting
1 parent fc3c3b6 commit 27d1f61

File tree

3 files changed

+12
-9
lines changed

3 files changed

+12
-9
lines changed

server/src/main/java/org/elasticsearch/cluster/metadata/IndexMetadata.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2038,7 +2038,7 @@ public Builder numberOfShards(int numberOfShards) {
20382038
* We do not support shrinking the shard count.
20392039
* @param shardCount updated shardCount
20402040
*/
2041-
public Builder reshardAddShards (int shardCount) {
2041+
public Builder reshardAddShards(int shardCount) {
20422042
// Assert routingNumShards is null ?
20432043
// Assert numberOfShards > 0
20442044
if (shardCount % numberOfShards() != 0) {

server/src/main/java/org/elasticsearch/cluster/metadata/Metadata.java

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2179,9 +2179,11 @@ public Builder updateNumberOfShards(final int numberOfShards, final String index
21792179
}
21802180
// IndexMetadata newIndexMetadata = indexMetadata.withIncrementedPrimaryShards(numberOfShards);
21812181
// put(IndexMetadata.builder(newIndexMetadata).numberOfShards(numberOfShards));
2182-
put(IndexMetadata.builder(indexMetadata)
2183-
.settingsVersion(indexMetadata.getSettingsVersion() + 1)
2184-
.reshardAddShards(numberOfShards));
2182+
put(
2183+
IndexMetadata.builder(indexMetadata)
2184+
.settingsVersion(indexMetadata.getSettingsVersion() + 1)
2185+
.reshardAddShards(numberOfShards)
2186+
);
21852187
return this;
21862188
}
21872189

server/src/main/java/org/elasticsearch/cluster/routing/UnassignedInfo.java

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -339,11 +339,12 @@ public void writeTo(StreamOutput out) throws IOException {
339339
out.writeByte((byte) Reason.NODE_LEFT.ordinal());
340340
} else if (reason.equals(Reason.UNPROMOTABLE_REPLICA) && out.getTransportVersion().before(VERSION_UNPROMOTABLE_REPLICA_ADDED)) {
341341
out.writeByte((byte) Reason.PRIMARY_FAILED.ordinal());
342-
} else if (reason.equals(Reason.RESHARD_ADDED) && out.getTransportVersion().before(TransportVersions.UNASSIGENEDINFO_RESHARD_ADDED)) {
343-
out.writeByte((byte) Reason.FORCED_EMPTY_PRIMARY.ordinal());
344-
} else {
345-
out.writeByte((byte) reason.ordinal());
346-
}
342+
} else if (reason.equals(Reason.RESHARD_ADDED)
343+
&& out.getTransportVersion().before(TransportVersions.UNASSIGENEDINFO_RESHARD_ADDED)) {
344+
out.writeByte((byte) Reason.FORCED_EMPTY_PRIMARY.ordinal());
345+
} else {
346+
out.writeByte((byte) reason.ordinal());
347+
}
347348
out.writeLong(unassignedTimeMillis);
348349
// Do not serialize unassignedTimeNanos as System.nanoTime() cannot be compared across different JVMs
349350
out.writeBoolean(delayed);

0 commit comments

Comments
 (0)