This is an automated email from the ASF dual-hosted git repository. upthewaterspout pushed a commit to branch feature/redis-performance-testing in repository https://gitbox.apache.org/repos/asf/geode.git
commit fa5768532352d0b0a934e8eabd09c1feb9d248e3 Author: Jens Deppe <[email protected]> AuthorDate: Thu Feb 18 11:15:55 2021 -0800 Make sure all buckets are created before computing slots --- .../geode/redis/internal/executor/cluster/ClusterExecutor.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/geode-redis/src/main/java/org/apache/geode/redis/internal/executor/cluster/ClusterExecutor.java b/geode-redis/src/main/java/org/apache/geode/redis/internal/executor/cluster/ClusterExecutor.java index f7e8315..6b7f2d2 100644 --- a/geode-redis/src/main/java/org/apache/geode/redis/internal/executor/cluster/ClusterExecutor.java +++ b/geode-redis/src/main/java/org/apache/geode/redis/internal/executor/cluster/ClusterExecutor.java @@ -80,6 +80,11 @@ public class ClusterExecutor extends AbstractExecutor { @SuppressWarnings("unchecked") private RedisResponse getSlots(ExecutionHandlerContext ctx) { Region<ByteArrayWrapper, RedisData> dataRegion = ctx.getRegionProvider().getDataRegion(); + + // Really only need this in situations where the cluster is empty and no data has been + // added yet. + PartitionRegionHelper.assignBucketsToPartitions(dataRegion); + PartitionRegionInfo info = PartitionRegionHelper.getPartitionRegionInfo(dataRegion); Set<DistributedMember> membersWithDataRegion = new HashSet<>(); for (PartitionMemberInfo memberInfo : info.getPartitionMemberInfo()) {
