chungen0126 commented on code in PR #4089:
URL: https://github.com/apache/ozone/pull/4089#discussion_r1054176078
##########
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/GrpcReplicationService.java:
##########
@@ -49,11 +49,13 @@ public GrpcReplicationService(ContainerReplicationSource
source) {
public void download(CopyContainerRequestProto request,
StreamObserver<CopyContainerResponseProto> responseObserver) {
long containerID = request.getContainerID();
- LOG.info("Streaming container data ({}) to other datanode", containerID);
+ String compression = request.getCompression().toString();
Review Comment:
finished
##########
hadoop-hdds/container-service/src/test/java/org/apache/hadoop/ozone/container/keyvalue/TestKeyValueContainer.java:
##########
@@ -211,7 +211,31 @@ public void testEmptyContainerImportExport() throws
Exception {
}
@Test
- public void testContainerImportExport() throws Exception {
+ public void testContainerImportExportUncompressed() throws Exception {
+ testContainerImportExport("no_compression");
+ }
+
+ @Test
+ public void testContainerImportExportGzip() throws Exception {
+ testContainerImportExport("gz");
+ }
+
+ @Test
+ public void testContainerImportExportZstd() throws Exception {
+ testContainerImportExport("zstd");
+ }
+
+ @Test
+ public void testContainerImportExportSnappy() throws Exception {
+ testContainerImportExport("snappy-framed");
+ }
+
+ @Test
+ public void testContainerImportExportLz4() throws Exception {
+ testContainerImportExport("lz4-framed");
+ }
Review Comment:
finished
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
