[CI] Auto commit changes from spotless

Author: elasticsearchmachine

server/src/main/java/org/elasticsearch/action/search/ClearScrollController.java

@@ -163,7 +163,8 @@ public static void closeContexts(
         ActionListener<Integer> listener
     ) {
         DiscoveryNodes nodes = clusterService.state().nodes();
-        final Set<String> clusters = shards.values().stream()
+        final Set<String> clusters = shards.values()
+            .stream()
             .map(SearchContextIdForNode::getClusterAlias)
             .filter(clusterAlias -> Strings.isEmpty(clusterAlias) == false)
             .collect(Collectors.toSet());
@@ -193,9 +194,11 @@ public static void closeContexts(
                         IndexShardRoutingTable indexShardRoutingTable = clusterService.state()
                             .routingTable(projectResolver.getProjectId())
                             .shardRoutingTable(entry.getKey());
-                        targetNodes = indexShardRoutingTable.assignedUnpromotableShards().stream()
-                                .map(ShardRouting::currentNodeId).map(nodeId -> nodeLookup.apply(contextId.getClusterAlias(), nodeId)).collect(
-                                        Collectors.toSet());
+                        targetNodes = indexShardRoutingTable.assignedUnpromotableShards()
+                            .stream()
+                            .map(ShardRouting::currentNodeId)
+                            .map(nodeId -> nodeLookup.apply(contextId.getClusterAlias(), nodeId))
+                            .collect(Collectors.toSet());
                         staticLogger.info("---> trying alternative nodes to close context: " + targetNodes);
                     }
                     for (DiscoveryNode targetNode : targetNodes) {

server/src/main/java/org/elasticsearch/search/SearchService.java

@@ -1245,9 +1245,9 @@ private ReaderContext findReaderContext(ShardSearchContextId id, TransportReques
         if (id.getSessionId().isEmpty()) {
             throw new IllegalArgumentException("Session id must be specified");
         }
-//        if (sessionId.equals(id.getSessionId()) == false) {
-//            throw new SearchContextMissingException(id);
-//        }
+        // if (sessionId.equals(id.getSessionId()) == false) {
+        // throw new SearchContextMissingException(id);
+        // }
         final ReaderContext reader = activeReaders.get(id.readerContextId());
         if (reader == null) {
             throw new SearchContextMissingException(id);
@@ -1848,10 +1848,10 @@ public long getDefaultKeepAliveInMillis() {
 
     public List<ReaderContext> getActiveContexts(ShardId shardId) {
         return this.activeReaders.values()
-                .stream()
-                .filter(c -> c.singleSession() == false)
-                .filter(c -> c.indexShard().shardId().equals(shardId))
-                .collect(Collectors.toList());
+            .stream()
+            .filter(c -> c.singleSession() == false)
+            .filter(c -> c.indexShard().shardId().equals(shardId))
+            .collect(Collectors.toList());
     }
 
     public void reopenPitContexts(ShardId shardId, String segmentsFileName, long keepAlive, String sessionId, long contextId) {
@@ -1860,17 +1860,16 @@ public void reopenPitContexts(ShardId shardId, String segmentsFileName, long kee
         ReaderContext readerContext = null;
         try {
             Directory directory = shard.store().directory();
-            SegmentInfos segmentCommitInfos = SegmentInfos.readCommit(directory, segmentsFileName,
-                    IndexVersions.MINIMUM_READONLY_COMPATIBLE.luceneVersion().major);
+            SegmentInfos segmentCommitInfos = SegmentInfos.readCommit(
+                directory,
+                segmentsFileName,
+                IndexVersions.MINIMUM_READONLY_COMPATIBLE.luceneVersion().major
+            );
             IndexCommit indexCommit = Lucene.getIndexCommit(segmentCommitInfos, directory);
             DirectoryReader open = StandardDirectoryReader.open(indexCommit);
 
             String searcherId = ReadOnlyEngine.generateSearcherId(segmentCommitInfos);
-            final ShardSearchContextId shardSearchContextId = new ShardSearchContextId(
-                    sessionId,
-                    contextId,
-                    searcherId
-            );
+            final ShardSearchContextId shardSearchContextId = new ShardSearchContextId(sessionId, contextId, searcherId);
             SearcherSupplier searchSupplier = new Engine.SearcherSupplier(Function.identity()) {
 
                 @Override
@@ -1883,13 +1882,12 @@ protected Searcher acquireSearcherInternal(String source) {
                     EngineConfig engineConfig = shard.getEngineOrNull().getEngineConfig();
 
                     return new Searcher(
-                            "source",
-                            open,
-                            engineConfig.getSimilarity(),
-                            engineConfig.getQueryCache(),
-                            engineConfig.getQueryCachingPolicy(),
-                            () -> {
-                            }
+                        "source",
+                        open,
+                        engineConfig.getSimilarity(),
+                        engineConfig.getQueryCache(),
+                        engineConfig.getQueryCachingPolicy(),
+                        () -> {}
                     );
                 }
             };

server/src/test/java/org/elasticsearch/action/search/TransportSearchActionTests.java

@@ -10,6 +10,7 @@
 package org.elasticsearch.action.search;
 
 import com.carrotsearch.randomizedtesting.generators.RandomPicks;
+
 import org.apache.lucene.search.TotalHits;
 import org.apache.lucene.util.SetOnce;
 import org.elasticsearch.TransportVersion;

test/framework/src/main/java/org/elasticsearch/test/ESTestCase.java

@@ -20,6 +20,7 @@
 import com.carrotsearch.randomizedtesting.generators.RandomPicks;
 import com.carrotsearch.randomizedtesting.generators.RandomStrings;
 import com.carrotsearch.randomizedtesting.rules.TestRuleAdapter;
+
 import org.apache.logging.log4j.Level;
 import org.apache.logging.log4j.LogManager;
 import org.apache.logging.log4j.Logger;