This is an automated email from the ASF dual-hosted git repository.
siddhant 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 5869b33daf HDDS-5098. Intermittent failure in
TestSCMNodeManager#testScmDetectStaleAndDeadNode (#5193)
5869b33daf is described below
commit 5869b33dafad6e07693dacc909d4472b5060d502
Author: Tejaskriya <[email protected]>
AuthorDate: Thu Aug 17 19:33:40 2023 +0530
HDDS-5098. Intermittent failure in
TestSCMNodeManager#testScmDetectStaleAndDeadNode (#5193)
---
.../test/java/org/apache/hadoop/hdds/scm/node/TestSCMNodeManager.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git
a/hadoop-hdds/server-scm/src/test/java/org/apache/hadoop/hdds/scm/node/TestSCMNodeManager.java
b/hadoop-hdds/server-scm/src/test/java/org/apache/hadoop/hdds/scm/node/TestSCMNodeManager.java
index 2f677629a0..e75f6e6f41 100644
---
a/hadoop-hdds/server-scm/src/test/java/org/apache/hadoop/hdds/scm/node/TestSCMNodeManager.java
+++
b/hadoop-hdds/server-scm/src/test/java/org/apache/hadoop/hdds/scm/node/TestSCMNodeManager.java
@@ -83,7 +83,6 @@ import org.junit.Assert;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import java.util.Map;
@@ -669,7 +668,6 @@ public class TestSCMNodeManager {
* @throws TimeoutException
*/
@Test
- @Disabled("HDDS-5098")
public void testScmDetectStaleAndDeadNode()
throws IOException, InterruptedException, AuthenticationException {
final int interval = 100;
@@ -721,13 +719,13 @@ public class TestSCMNodeManager {
"Expected to find 1 stale node");
assertEquals(staleNode.getUuid(), staleNodeList.get(0).getUuid(),
"Stale node is not the expected ID");
- Thread.sleep(1000);
Map<String, Map<String, Integer>> nodeCounts =
nodeManager.getNodeCount();
assertEquals(1,
nodeCounts.get(HddsProtos.NodeOperationalState.IN_SERVICE.name())
.get(HddsProtos.NodeState.STALE.name()).intValue());
+ Thread.sleep(1000);
// heartbeat good nodes again.
for (DatanodeDetails dn : nodeList) {
nodeManager.processHeartbeat(dn, layoutInfo);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
