9
9
package org .elasticsearch .action .admin .cluster .shards ;
10
10
11
11
import org .elasticsearch .TransportVersion ;
12
+ import org .elasticsearch .Version ;
12
13
import org .elasticsearch .cluster .node .DiscoveryNode ;
13
14
import org .elasticsearch .cluster .node .DiscoveryNodeUtils ;
14
15
import org .elasticsearch .cluster .routing .ShardRouting ;
20
21
import org .elasticsearch .common .io .stream .StreamInput ;
21
22
import org .elasticsearch .common .settings .Settings ;
22
23
import org .elasticsearch .common .transport .TransportAddress ;
24
+ import org .elasticsearch .index .IndexVersion ;
23
25
import org .elasticsearch .index .query .RandomQueryBuilder ;
24
26
import org .elasticsearch .index .shard .ShardId ;
25
27
import org .elasticsearch .search .SearchModule ;
26
28
import org .elasticsearch .search .internal .AliasFilter ;
27
29
import org .elasticsearch .test .ESTestCase ;
28
30
import org .elasticsearch .test .TransportVersionUtils ;
29
- import org .elasticsearch .test .VersionUtils ;
30
31
31
32
import java .util .ArrayList ;
32
33
import java .util .Collections ;
36
37
import java .util .Map ;
37
38
import java .util .Set ;
38
39
40
+ import static org .elasticsearch .test .VersionUtils .randomCompatibleVersion ;
41
+
39
42
public class ClusterSearchShardsResponseTests extends ESTestCase {
40
43
41
44
public void testSerialization () throws Exception {
@@ -49,12 +52,10 @@ public void testSerialization() throws Exception {
49
52
String nodeId = randomAlphaOfLength (10 );
50
53
ShardRouting shardRouting = TestShardRouting .newShardRouting (shardId , nodeId , randomBoolean (), ShardRoutingState .STARTED );
51
54
clusterSearchShardsGroups [i ] = new ClusterSearchShardsGroup (shardId , new ShardRouting [] { shardRouting });
52
- DiscoveryNode node = DiscoveryNodeUtils .create (
53
- shardRouting .currentNodeId (),
54
- new TransportAddress (TransportAddress .META_ADDRESS , randomInt (0xFFFF )),
55
- VersionUtils .randomVersion (random ())
56
- );
57
- nodes .add (node );
55
+ DiscoveryNodeUtils .Builder node = DiscoveryNodeUtils .builder (shardRouting .currentNodeId ())
56
+ .address (new TransportAddress (TransportAddress .META_ADDRESS , randomInt (0xFFFF )))
57
+ .version (randomCompatibleVersion (random (), Version .CURRENT ), IndexVersion .MINIMUM_COMPATIBLE , IndexVersion .current ());
58
+ nodes .add (node .build ());
58
59
AliasFilter aliasFilter ;
59
60
if (randomBoolean ()) {
60
61
aliasFilter = AliasFilter .of (RandomQueryBuilder .createQuery (random ()), "alias-" + index );
0 commit comments