File tree Expand file tree Collapse file tree 2 files changed +11
-9
lines changed
server/src/internalClusterTest/java/org/elasticsearch/index/engine
test/framework/src/main/java/org/elasticsearch/test Expand file tree Collapse file tree 2 files changed +11
-9
lines changed Original file line number Diff line number Diff line change @@ -133,8 +133,8 @@ public void testMergesUseTheMergeThreadPool() throws Exception {
133133
134134 // after a force merge there should only be 1 segment per shard
135135 var shardsWithMultipleSegments = getShardSegments ().stream ()
136- .filter (shardSegments -> shardSegments .getSegments ().size () > 1 )
137- .toList ();
136+ .filter (shardSegments -> shardSegments .getSegments ().size () > 1 )
137+ .toList ();
138138 assertTrue ("there are shards with multiple segments " + shardsWithMultipleSegments , shardsWithMultipleSegments .isEmpty ());
139139
140140 final long expectedTotalDocs = totalDocs ;
Original file line number Diff line number Diff line change 99
1010package org .elasticsearch .test ;
1111
12+ import io .netty .util .ThreadDeathWatcher ;
13+ import io .netty .util .concurrent .GlobalEventExecutor ;
14+
1215import com .carrotsearch .randomizedtesting .RandomizedContext ;
1316import com .carrotsearch .randomizedtesting .generators .RandomNumbers ;
1417import com .carrotsearch .randomizedtesting .generators .RandomPicks ;
15- import io .netty .util .ThreadDeathWatcher ;
16- import io .netty .util .concurrent .GlobalEventExecutor ;
18+
1719import org .apache .http .HttpHost ;
1820import org .apache .logging .log4j .Logger ;
1921import org .apache .lucene .search .Sort ;
@@ -1608,11 +1610,11 @@ protected BroadcastResponse forceMerge() {
16081610 protected List <ShardSegments > getShardSegments (String ... indices ) {
16091611 IndicesSegmentResponse indicesSegmentResponse = indicesAdmin ().prepareSegments (indices ).get ();
16101612 return indicesSegmentResponse .getIndices ()
1611- .values ()
1612- .stream ()
1613- .flatMap (indexSegments -> indexSegments .getShards ().values ().stream ())
1614- .flatMap (indexShardSegments -> Stream .of (indexShardSegments .shards ()))
1615- .toList ();
1613+ .values ()
1614+ .stream ()
1615+ .flatMap (indexSegments -> indexSegments .getShards ().values ().stream ())
1616+ .flatMap (indexShardSegments -> Stream .of (indexShardSegments .shards ()))
1617+ .toList ();
16161618 }
16171619
16181620 /**
You can’t perform that action at this time.
0 commit comments