@@ -213,8 +213,9 @@ public void testForgetFollower() throws IOException {
213213 final CcrClient ccrClient = highLevelClient ().ccr ();
214214
215215 final CreateIndexRequest createIndexRequest = new CreateIndexRequest ("leader" );
216- final Map <String , String > settings = new HashMap <>(2 );
216+ final Map <String , String > settings = new HashMap <>(3 );
217217 final int numberOfShards = randomIntBetween (1 , 2 );
218+ settings .put ("index.number_of_replicas" , "0" );
218219 settings .put ("index.number_of_shards" , Integer .toString (numberOfShards ));
219220 settings .put ("index.soft_deletes.enabled" , Boolean .TRUE .toString ());
220221 createIndexRequest .settings (settings );
@@ -251,10 +252,12 @@ public void testForgetFollower() throws IOException {
251252 final Request retentionLeasesRequest = new Request ("GET" , "/leader/_stats" );
252253 retentionLeasesRequest .addParameter ("level" , "shards" );
253254 final Response retentionLeasesResponse = client ().performRequest (retentionLeasesRequest );
255+ final Map <?, ?> shardsStats = ObjectPath .createFromResponse (retentionLeasesResponse ).evaluate ("indices.leader.shards" );
256+ assertThat (shardsStats .keySet (), hasSize (numberOfShards ));
254257 for (int i = 0 ; i < numberOfShards ; i ++) {
255- final List <?> shardsStats = ObjectPath . createFromResponse ( retentionLeasesResponse ). evaluate ( "indices.leader.shards." + i );
256- assertThat (shardsStats , hasSize (1 ));
257- final Map <?, ?> shardStatsAsMap = (Map <?, ?>) shardsStats .get (0 );
258+ final List <?> shardStats = ( List <?>) shardsStats . get ( Integer . toString ( i ) );
259+ assertThat (shardStats , hasSize (1 ));
260+ final Map <?, ?> shardStatsAsMap = (Map <?, ?>) shardStats .get (0 );
258261 final Map <?, ?> retentionLeasesStats = (Map <?, ?>) shardStatsAsMap .get ("retention_leases" );
259262 final List <?> leases = (List <?>) retentionLeasesStats .get ("leases" );
260263 assertThat (leases , empty ());
0 commit comments