Skip to content

Commit f066b04

Browse files
author
elasticsearchmachine
committed
[CI] Auto commit changes from spotless
1 parent 23ae255 commit f066b04

File tree

6 files changed

+12
-7
lines changed

6 files changed

+12
-7
lines changed

server/src/main/java/org/elasticsearch/cluster/routing/allocation/shards/ShardsAvailabilityHealthIndicatorService.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -78,7 +78,6 @@
7878
import java.util.stream.Stream;
7979

8080
import static java.util.stream.Collectors.joining;
81-
import static java.util.stream.Collectors.toMap;
8281
import static java.util.stream.Collectors.toSet;
8382
import static org.elasticsearch.cluster.health.ClusterShardHealth.getInactivePrimaryHealth;
8483
import static org.elasticsearch.cluster.metadata.IndexMetadata.INDEX_ROUTING_INCLUDE_GROUP_PREFIX;

server/src/main/java/org/elasticsearch/indices/SystemIndices.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,8 @@
2525
import org.elasticsearch.client.internal.Client;
2626
import org.elasticsearch.client.internal.OriginSettingClient;
2727
import org.elasticsearch.cluster.metadata.ProjectMetadata;
28-
import org.elasticsearch.cluster.project.ProjectResolver;
2928
import org.elasticsearch.cluster.metadata.SystemIndexMetadataUpgradeService;
29+
import org.elasticsearch.cluster.project.ProjectResolver;
3030
import org.elasticsearch.cluster.service.ClusterService;
3131
import org.elasticsearch.common.Strings;
3232
import org.elasticsearch.common.settings.Settings;

x-pack/plugin/core/src/main/java/org/elasticsearch/xpack/core/deprecation/DeprecatedIndexPredicate.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,11 @@ public class DeprecatedIndexPredicate {
3333
* if false, only non-system indices are returned
3434
* @return a predicate that returns true for indices that need to be reindexed
3535
*/
36-
public static Predicate<Index> getReindexRequiredPredicate(ProjectMetadata metadata, boolean filterToBlockedStatus,
37-
boolean includeSystem) {
36+
public static Predicate<Index> getReindexRequiredPredicate(
37+
ProjectMetadata metadata,
38+
boolean filterToBlockedStatus,
39+
boolean includeSystem
40+
) {
3841
return index -> {
3942
IndexMetadata indexMetadata = metadata.index(index);
4043
return reindexRequired(indexMetadata, filterToBlockedStatus, includeSystem);

x-pack/plugin/deprecation/src/main/java/org/elasticsearch/xpack/deprecation/DataStreamDeprecationChecker.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -137,7 +137,9 @@ private static Set<String> getReindexRequiredIndices(
137137
boolean filterToBlockedStatus
138138
) {
139139
return backingIndices.stream()
140-
.filter(DeprecatedIndexPredicate.getReindexRequiredPredicate(clusterState.metadata().getProject(), filterToBlockedStatus, false))
140+
.filter(
141+
DeprecatedIndexPredicate.getReindexRequiredPredicate(clusterState.metadata().getProject(), filterToBlockedStatus, false)
142+
)
141143
.map(Index::getName)
142144
.collect(Collectors.toUnmodifiableSet());
143145
}

x-pack/plugin/migrate/src/main/java/org/elasticsearch/system_indices/task/SystemResourceMigrationInfo.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import org.elasticsearch.client.internal.Client;
1212
import org.elasticsearch.client.internal.OriginSettingClient;
1313
import org.elasticsearch.cluster.metadata.IndexMetadata;
14-
import org.elasticsearch.cluster.metadata.Metadata;
1514
import org.elasticsearch.cluster.metadata.ProjectMetadata;
1615
import org.elasticsearch.cluster.service.ClusterService;
1716
import org.elasticsearch.indices.SystemIndices;

x-pack/plugin/migrate/src/main/java/org/elasticsearch/xpack/migrate/task/ReindexDataStreamPersistentTaskExecutor.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,9 @@ protected void nodeOperation(
125125
if (dataStreamInfos.size() == 1) {
126126
DataStream dataStream = dataStreamInfos.getFirst().getDataStream();
127127
boolean includeSystem = dataStream.isSystem();
128-
if (getReindexRequiredPredicate(clusterService.state().metadata().getProject(), false, includeSystem).test(dataStream.getWriteIndex())) {
128+
if (getReindexRequiredPredicate(clusterService.state().metadata().getProject(), false, includeSystem).test(
129+
dataStream.getWriteIndex()
130+
)) {
129131
RolloverRequest rolloverRequest = new RolloverRequest(sourceDataStream, null);
130132
rolloverRequest.setParentTask(taskId);
131133
client.execute(

0 commit comments

Comments
 (0)