This is an automated email from the ASF dual-hosted git repository.

xingtanzjr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 20d62dd5e0 fix 20s to 60s. (#6587)
20d62dd5e0 is described below

commit 20d62dd5e0221246091037e4f1a2f0de50b936d6
Author: ZhangHongYin <[email protected]>
AuthorDate: Mon Jul 4 22:46:05 2022 +0800

    fix 20s to 60s. (#6587)
---
 .../iotdb/consensus/multileader/MultiLeaderConsensusTest.java       | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/consensus/src/test/java/org/apache/iotdb/consensus/multileader/MultiLeaderConsensusTest.java
 
b/consensus/src/test/java/org/apache/iotdb/consensus/multileader/MultiLeaderConsensusTest.java
index 771b600c69..36437d5a22 100644
--- 
a/consensus/src/test/java/org/apache/iotdb/consensus/multileader/MultiLeaderConsensusTest.java
+++ 
b/consensus/src/test/java/org/apache/iotdb/consensus/multileader/MultiLeaderConsensusTest.java
@@ -138,7 +138,7 @@ public class MultiLeaderConsensusTest {
       while (servers.get(i).getImpl(gid).getCurrentSafelyDeletedSearchIndex()
           < IndexController.FLUSH_INTERVAL) {
         long current = System.currentTimeMillis();
-        if ((current - start) > 20 * 1000) {
+        if ((current - start) > 60 * 1000) {
           Assert.fail("Unable to replicate entries");
         }
         Thread.sleep(100);
@@ -179,7 +179,7 @@ public class MultiLeaderConsensusTest {
       while (servers.get(i).getImpl(gid).getCurrentSafelyDeletedSearchIndex()
           < IndexController.FLUSH_INTERVAL) {
         long current = System.currentTimeMillis();
-        if ((current - start) > 20 * 1000) {
+        if ((current - start) > 60 * 1000) {
           Assert.fail("Unable to recover entries");
         }
         Thread.sleep(100);
@@ -241,7 +241,7 @@ public class MultiLeaderConsensusTest {
       while (servers.get(i).getImpl(gid).getCurrentSafelyDeletedSearchIndex()
           < IndexController.FLUSH_INTERVAL) {
         long current = System.currentTimeMillis();
-        if ((current - start) > 20 * 1000) {
+        if ((current - start) > 60 * 1000) {
           logger.error("{}", 
servers.get(i).getImpl(gid).getCurrentSafelyDeletedSearchIndex());
           Assert.fail("Unable to replicate entries");
         }

Reply via email to