@@ -283,12 +283,12 @@ public void testDownloadStatsCorrectnessSinglePrimarySingleReplica() throws Exce
283283 // Existing validation logic
284284 List <RemoteStoreStats > primaryStatsList = Arrays .stream (response .getRemoteStoreStats ())
285285 .filter (remoteStoreStats -> remoteStoreStats .getShardRouting ().primary ())
286- .toList ();
286+ .collect ( Collectors . toList () );
287287 assertEquals (1 , primaryStatsList .size ());
288288
289289 List <RemoteStoreStats > replicaStatsList = Arrays .stream (response .getRemoteStoreStats ())
290290 .filter (remoteStoreStats -> !remoteStoreStats .getShardRouting ().primary ())
291- .toList ();
291+ .collect ( Collectors . toList () );
292292 assertEquals (1 , replicaStatsList .size ());
293293
294294 RemoteSegmentTransferTracker .Stats primaryStats = primaryStatsList .getFirst ().getSegmentStats ();
@@ -401,7 +401,7 @@ private void validateZeroStatePrimaryStats(RemoteSegmentTransferTracker.Stats pr
401401 private void validateZeroStateReplicaStats (RemoteStoreStatsResponse zeroStateResponse , boolean multipleShardsExpected ) {
402402 List <RemoteStoreStats > zeroStateReplicaStats = Arrays .stream (zeroStateResponse .getRemoteStoreStats ())
403403 .filter (remoteStoreStats -> !remoteStoreStats .getShardRouting ().primary ())
404- .toList ();
404+ .collect ( Collectors . toList () );
405405
406406 if (multipleShardsExpected ) {
407407 zeroStateReplicaStats .forEach (stats -> {
@@ -434,8 +434,8 @@ private SetOnce<RemoteSegmentTransferTracker.Stats> prepareZeroStateStats(
434434
435435 RemoteSegmentTransferTracker .Stats primaryStats = Arrays .stream (zeroStateResponse .getRemoteStoreStats ())
436436 .filter (remoteStoreStats -> remoteStoreStats .getShardRouting ().primary ())
437- .toList ()
438- .getFirst ( )
437+ .collect ( Collectors . toList () )
438+ .get ( 0 )
439439 .getSegmentStats ();
440440
441441 validateZeroStatePrimaryStats (primaryStats );
0 commit comments