This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 9bc3b590b9a HDDS-16256. Avoid the per-group list copy in
OMKeyRequest.filterOutBlocksStillInUse (#11115)
9bc3b590b9a is described below
commit 9bc3b590b9a924b1f51509c994221cd9785caf4a
Author: Mark Tsai <[email protected]>
AuthorDate: Mon Aug 31 16:40:48 2026 +0800
HDDS-16256. Avoid the per-group list copy in
OMKeyRequest.filterOutBlocksStillInUse (#11115)
---
.../main/java/org/apache/hadoop/ozone/om/request/key/OMKeyRequest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
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<Map<OmKeyInfo, List<OmKeyLocationInfo>>,
Integer> filterOutBlocks
// the referenceKey.
Map<ContainerBlockID, OmKeyLocationInfo> 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<OmKeyInfo, List<OmKeyLocationInfo>> filteredOutBlocks = new
HashMap<>();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
