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 6389d01605 HDDS-7856. Fix timeout in TestPushReplicator (#4225)
6389d01605 is described below
commit 6389d01605053a9a5ae5510b67fb2bc6204db9d2
Author: Doroszlai, Attila <[email protected]>
AuthorDate: Tue Jan 31 15:42:14 2023 +0100
HDDS-7856. Fix timeout in TestPushReplicator (#4225)
---
.../hadoop/ozone/container/replication/TestPushReplicator.java | 7 ++++---
1 file changed, 4 insertions(+), 3 deletions(-)
diff --git
a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/replication/TestPushReplicator.java
b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/replication/TestPushReplicator.java
index 0d0edd189c..791a0caa14 100644
---
a/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/replication/TestPushReplicator.java
+++
b/hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/replication/TestPushReplicator.java
@@ -21,8 +21,8 @@ import org.apache.hadoop.hdds.protocol.DatanodeDetails;
import org.apache.hadoop.hdds.protocol.MockDatanodeDetails;
import
org.apache.hadoop.ozone.container.replication.AbstractReplicationTask.Status;
import org.apache.ozone.test.SpyOutputStream;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.Timeout;
import org.mockito.ArgumentCaptor;
import java.io.IOException;
@@ -35,6 +35,7 @@ import static
org.apache.commons.io.output.NullOutputStream.NULL_OUTPUT_STREAM;
import static
org.apache.hadoop.ozone.container.replication.CopyContainerCompression.NO_COMPRESSION;
import static
org.apache.hadoop.ozone.protocol.commands.ReplicateContainerCommand.toTarget;
import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.mockito.ArgumentMatchers.any;
import static org.mockito.ArgumentMatchers.eq;
import static org.mockito.Mockito.doAnswer;
import static org.mockito.Mockito.mock;
@@ -43,7 +44,7 @@ import static org.mockito.Mockito.when;
/**
* Test for {@link PushReplicator}.
*/
-@Disabled("HDDS-7856")
+@Timeout(30)
class TestPushReplicator {
@Test
@@ -131,7 +132,7 @@ class TestPushReplicator {
return null;
})
.when(source)
- .copyData(containerID, outputStream, NO_COMPRESSION.name());
+ .copyData(eq(containerID), any(), eq(NO_COMPRESSION.name()));
return new PushReplicator(source, uploader);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
