@@ -283,16 +283,16 @@ 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
- RemoteSegmentTransferTracker .Stats primaryStats = primaryStatsList .getFirst ( ).getSegmentStats ();
295
- RemoteSegmentTransferTracker .Stats replicaStats = replicaStatsList .getFirst ( ).getSegmentStats ();
294
+ RemoteSegmentTransferTracker .Stats primaryStats = primaryStatsList .get ( 0 ).getSegmentStats ();
295
+ RemoteSegmentTransferTracker .Stats replicaStats = replicaStatsList .get ( 0 ).getSegmentStats ();
296
296
297
297
// Existing assertions
298
298
assertTrue (primaryStats .totalUploadsStarted > 0 );
@@ -409,7 +409,7 @@ private void validateZeroStateReplicaStats(RemoteStoreStatsResponse zeroStateRes
409
409
assertEquals (0 , stats .getSegmentStats ().directoryFileTransferTrackerStats .transferredBytesSucceeded );
410
410
});
411
411
} else {
412
- RemoteSegmentTransferTracker .Stats replicaStats = zeroStateReplicaStats .getFirst ( ).getSegmentStats ();
412
+ RemoteSegmentTransferTracker .Stats replicaStats = zeroStateReplicaStats .get ( 0 ).getSegmentStats ();
413
413
assertEquals (0 , replicaStats .directoryFileTransferTrackerStats .transferredBytesStarted );
414
414
assertEquals (0 , replicaStats .directoryFileTransferTrackerStats .transferredBytesSucceeded );
415
415
}
@@ -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