You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by ad...@apache.org on 2023/02/14 08:51:55 UTC
[ozone] branch master updated: HDDS-7617. Intermittent timeout in TestECContainerRecovery (#4268)
This is an automated email from the ASF dual-hosted git repository.
adoroszlai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 55cc72e377 HDDS-7617. Intermittent timeout in TestECContainerRecovery (#4268)
55cc72e377 is described below
commit 55cc72e377352d17188c416fe7c9bc5007c471b3
Author: Chung En Lee <wf...@gmail.com>
AuthorDate: Tue Feb 14 16:51:47 2023 +0800
HDDS-7617. Intermittent timeout in TestECContainerRecovery (#4268)
---
.../apache/hadoop/ozone/container/TestECContainerRecovery.java | 8 ++++++++
1 file changed, 8 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 77c00f2cdc..076d0edeb5 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
@@ -228,6 +228,7 @@ public class TestECContainerRecovery {
.ContainerReplicaProto.State.CLOSED, container.containerID());
//Temporarily stop the RM process.
scm.getReplicationManager().stop();
+ waitForReplicationManagerStopped(scm.getReplicationManager());
// Wait for the lower replication.
waitForContainerCount(4, container.containerID(), scm);
@@ -240,6 +241,7 @@ public class TestECContainerRecovery {
// Let's verify for Over replications now.
//Temporarily stop the RM process.
scm.getReplicationManager().stop();
+ waitForReplicationManagerStopped(scm.getReplicationManager());
// Restart the DN to make the over replication and expect replication to be
// increased.
@@ -329,6 +331,7 @@ public class TestECContainerRecovery {
.ContainerReplicaProto.State.CLOSED, container.containerID());
//Temporarily stop the RM process.
scm.getReplicationManager().stop();
+ waitForReplicationManagerStopped(scm.getReplicationManager());
// Wait for the lower replication.
waitForContainerCount(4, container.containerID(), scm);
@@ -405,4 +408,9 @@ public class TestECContainerRecovery {
return inputData;
}
+ private void waitForReplicationManagerStopped(ReplicationManager rm)
+ throws TimeoutException, InterruptedException {
+ GenericTestUtils.waitFor(() -> !rm.isRunning(), 100, 10000);
+ }
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@ozone.apache.org
For additional commands, e-mail: commits-help@ozone.apache.org