@@ -283,12 +283,12 @@ public void testDownloadStatsCorrectnessSinglePrimarySingleReplica() throws Exce
283
283
// Existing validation logic
284
284
List <RemoteStoreStats > primaryStatsList = Arrays .stream (response .getRemoteStoreStats ())
285
285
.filter (remoteStoreStats -> remoteStoreStats .getShardRouting ().primary ())
286
- .toList ();
286
+ .collect ( Collectors . toList () );
287
287
assertEquals (1 , primaryStatsList .size ());
288
288
289
289
List <RemoteStoreStats > replicaStatsList = Arrays .stream (response .getRemoteStoreStats ())
290
290
.filter (remoteStoreStats -> !remoteStoreStats .getShardRouting ().primary ())
291
- .toList ();
291
+ .collect ( Collectors . toList () );
292
292
assertEquals (1 , replicaStatsList .size ());
293
293
294
294
RemoteSegmentTransferTracker .Stats primaryStats = primaryStatsList .getFirst ().getSegmentStats ();
@@ -401,7 +401,7 @@ private void validateZeroStatePrimaryStats(RemoteSegmentTransferTracker.Stats pr
401
401
private void validateZeroStateReplicaStats (RemoteStoreStatsResponse zeroStateResponse , boolean multipleShardsExpected ) {
402
402
List <RemoteStoreStats > zeroStateReplicaStats = Arrays .stream (zeroStateResponse .getRemoteStoreStats ())
403
403
.filter (remoteStoreStats -> !remoteStoreStats .getShardRouting ().primary ())
404
- .toList ();
404
+ .collect ( Collectors . toList () );
405
405
406
406
if (multipleShardsExpected ) {
407
407
zeroStateReplicaStats .forEach (stats -> {
@@ -434,8 +434,8 @@ private SetOnce<RemoteSegmentTransferTracker.Stats> prepareZeroStateStats(
434
434
435
435
RemoteSegmentTransferTracker .Stats primaryStats = Arrays .stream (zeroStateResponse .getRemoteStoreStats ())
436
436
.filter (remoteStoreStats -> remoteStoreStats .getShardRouting ().primary ())
437
- .toList ()
438
- .getFirst ( )
437
+ .collect ( Collectors . toList () )
438
+ .get ( 0 )
439
439
.getSegmentStats ();
440
440
441
441
validateZeroStatePrimaryStats (primaryStats );
0 commit comments