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");
}