You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by ri...@apache.org on 2022/02/11 21:47:34 UTC
[geode] branch WIP-GEODE-9892 updated: no buckets
This is an automated email from the ASF dual-hosted git repository.
ringles pushed a commit to branch WIP-GEODE-9892
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/WIP-GEODE-9892 by this push:
new a134aad no buckets
a134aad is described below
commit a134aad67cf4f122c506e83c5b780aaa37dfb9e5
Author: Ray Ingles <ri...@vmware.com>
AuthorDate: Fri Feb 11 16:44:57 2022 -0500
no buckets
---
.../redis/internal/commands/executor/list/LPopDUnitTest.java | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
diff --git a/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPopDUnitTest.java b/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPopDUnitTest.java
index becb172..4de22e2 100644
--- a/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPopDUnitTest.java
+++ b/geode-for-redis/src/distributedTest/java/org/apache/geode/redis/internal/commands/executor/list/LPopDUnitTest.java
@@ -20,7 +20,6 @@ import static org.apache.geode.test.dunit.rules.RedisClusterStartupRule.REDIS_CL
import static org.assertj.core.api.Assertions.assertThat;
import static org.assertj.core.api.Assertions.fail;
-import java.time.Duration;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Future;
@@ -37,7 +36,6 @@ import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import org.apache.geode.logging.internal.log4j.api.LogService;
-import org.apache.geode.test.awaitility.GeodeAwaitility;
import org.apache.geode.test.dunit.rules.MemberVM;
import org.apache.geode.test.dunit.rules.RedisClusterStartupRule;
import org.apache.geode.test.junit.rules.ExecutorServiceRule;
@@ -116,10 +114,10 @@ public class LPopDUnitTest {
Future<Void> future2 = executor.runAsync(task2);
Future<Void> future3 = executor.runAsync(task3);
- for (int i = 0; i < 100 && runningCount.get() > 0; i++) {
- clusterStartUp.moveBucketForKey(listHashtags.get(i % listHashtags.size()));
- GeodeAwaitility.await().during(Duration.ofMillis(200)).until(() -> true);
- }
+ // for (int i = 0; i < 100 && runningCount.get() > 0; i++) {
+ // clusterStartUp.moveBucketForKey(listHashtags.get(i % listHashtags.size()));
+ // GeodeAwaitility.await().during(Duration.ofMillis(200)).until(() -> true);
+ // }
runningCount.set(0);