This is an automated email from the ASF dual-hosted git repository.
ckj pushed a commit to branch ozone-1.3
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/ozone-1.3 by this push:
new 6d73f6f6dd HDDS-7326. Intermittent timeout in
TestECContainerRecovery.testContainerRecoveryOverReplicationProcessing (#3941)
6d73f6f6dd is described below
commit 6d73f6f6dda497c788e43430c892135992b7a683
Author: Swaminathan Balachandran <[email protected]>
AuthorDate: Mon Nov 7 23:15:34 2022 -0700
HDDS-7326. Intermittent timeout in
TestECContainerRecovery.testContainerRecoveryOverReplicationProcessing (#3941)
---
.../hadoop/ozone/container/TestECContainerRecovery.java | 13 +++++++++++++
1 file changed, 13 insertions(+)
diff --git
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/TestECContainerRecovery.java
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/TestECContainerRecovery.java
index 38ec64cb3f..764213c169 100644
---
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/TestECContainerRecovery.java
+++
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/ozone/container/TestECContainerRecovery.java
@@ -50,6 +50,8 @@ import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import java.io.IOException;
+import java.time.Duration;
+import java.time.temporal.ChronoUnit;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
@@ -94,6 +96,17 @@ public class TestECContainerRecovery {
conf.setFromObject(clientConfig);
conf.setTimeDuration(HDDS_SCM_WATCHER_TIMEOUT, 1000,
TimeUnit.MILLISECONDS);
+ ReplicationManager.ReplicationManagerConfiguration rmConfig = conf
+ .getObject(
+ ReplicationManager.ReplicationManagerConfiguration.class);
+ //Setting all the intervals to 10 seconds current tests have timeout
+ // of 100s.
+ rmConfig.setUnderReplicatedInterval(Duration.of(10,
+ ChronoUnit.SECONDS));
+ rmConfig.setOverReplicatedInterval(Duration.of(10,
+ ChronoUnit.SECONDS));
+ rmConfig.setInterval(Duration.of(10, ChronoUnit.SECONDS));
+ conf.setFromObject(rmConfig);
conf.set(ScmConfigKeys.OZONE_SCM_DEADNODE_INTERVAL, "1s");
conf.set(ScmConfigKeys.OZONE_SCM_STALENODE_INTERVAL, "1s");
conf.set(HddsConfigKeys.HDDS_CONTAINER_REPORT_INTERVAL, "1s");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
