diff --git a/geode-wan/src/main/java/org/apache/geode/management/internal/cli/functions/WanCopyRegionFunctionDelegate.java b/geode-wan/src/main/java/org/apache/geode/management/internal/cli/functions/WanCopyRegionFunctionDelegate.java index fdf85a5fcdf1..8e3d7de32ba3 100644 --- a/geode-wan/src/main/java/org/apache/geode/management/internal/cli/functions/WanCopyRegionFunctionDelegate.java +++ b/geode-wan/src/main/java/org/apache/geode/management/internal/cli/functions/WanCopyRegionFunctionDelegate.java @@ -26,8 +26,6 @@ import java.util.Iterator; import java.util.List; import java.util.Optional; -import java.util.Set; -import java.util.stream.Collectors; import org.apache.logging.log4j.Logger; @@ -186,13 +184,11 @@ private Optional sendBatch(String memberName, return batch; } - private Set getEntries(Region region, GatewaySender sender) { + private List getEntries(Region region, GatewaySender sender) { if (region instanceof PartitionedRegion && sender.isParallel()) { - return ((PartitionedRegion) region).getDataStore().getAllLocalBucketRegions() - .stream() - .flatMap(br -> ((Set) br.entrySet()).stream()).collect(Collectors.toSet()); + return ((PartitionedRegion) region).getDataStore().getEntries(); } - return region.entrySet(); + return new ArrayList<>(region.entrySet()); } /**