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 dabdedd5ad HDDS-5604. Intermittent failure in TestPipelineClose (#5825)
dabdedd5ad is described below
commit dabdedd5addc3d2c2c94cd210e202c3cb89a8acc
Author: Devesh Kumar Singh <[email protected]>
AuthorDate: Wed Dec 20 02:15:44 2023 +0530
HDDS-5604. Intermittent failure in TestPipelineClose (#5825)
---
.../org/apache/hadoop/hdds/scm/pipeline/TestPipelineClose.java | 7 +------
1 file changed, 1 insertion(+), 6 deletions(-)
diff --git
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/hdds/scm/pipeline/TestPipelineClose.java
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/hdds/scm/pipeline/TestPipelineClose.java
index 6c66ecf318..99dd1d1768 100644
---
a/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/hdds/scm/pipeline/TestPipelineClose.java
+++
b/hadoop-ozone/integration-test/src/test/java/org/apache/hadoop/hdds/scm/pipeline/TestPipelineClose.java
@@ -47,7 +47,6 @@ import org.apache.ozone.test.GenericTestUtils;
import org.apache.ratis.protocol.RaftGroupId;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
-import org.apache.ozone.test.tag.Flaky;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.Timeout;
import org.mockito.ArgumentCaptor;
@@ -209,10 +208,8 @@ public class TestPipelineClose {
}
@Test
- @Flaky("HDDS-5604")
public void testPipelineCloseWithLogFailure()
throws IOException, TimeoutException {
-
EventQueue eventQ = (EventQueue) scm.getEventQueue();
PipelineActionHandler pipelineActionTest =
Mockito.mock(PipelineActionHandler.class);
@@ -247,9 +244,7 @@ public class TestPipelineClose {
* This is expected to trigger an immediate pipeline actions report to SCM
*/
xceiverRatis.handleNodeLogFailure(groupId, null);
-
- // verify SCM receives a pipeline action report "immediately"
- Mockito.verify(pipelineActionTest, Mockito.timeout(100))
+ Mockito.verify(pipelineActionTest, Mockito.timeout(1500).atLeastOnce())
.onMessage(
actionCaptor.capture(),
Mockito.any(EventPublisher.class));
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
