diff --git a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/request/key/OMKeyRequest.java b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/request/key/OMKeyRequest.java index ce76ea9dc44..3d478e46139 100644 --- a/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/request/key/OMKeyRequest.java +++ b/hadoop-ozone/ozone-manager/src/main/java/org/apache/hadoop/ozone/om/request/key/OMKeyRequest.java @@ -1255,7 +1255,8 @@ protected Pair>, Integer> filterOutBlocks // the referenceKey. Map cbIdSet = referenceKey.getKeyLocationVersions() .stream() - .flatMap(e -> e.createLocationList().stream()) + .flatMap(group -> group.getLocationLists().stream()) + .flatMap(List::stream) .collect(Collectors.toMap(omKeyLocationInfo -> omKeyLocationInfo.getBlockID().getContainerBlockID(), Function.identity())); Map> filteredOutBlocks = new HashMap<>();