[ozone] 03/27: revert DownloadAndImportReplicator

[el...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

elek pushed a commit to branch HDDS-3816-ec
in repository https://gitbox.apache.org/repos/asf/ozone.git

commit 09477f52a1441038522d6149629521ae57182165
Author: Elek Márton <el...@apache.org>
AuthorDate: Thu Jan 14 11:43:42 2021 +0100

    revert DownloadAndImportReplicator
---
 .../ozone/container/replication/DownloadAndImportReplicator.java  | 8 ++------
 1 file changed, 2 insertions(+), 6 deletions(-)

diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/DownloadAndImportReplicator.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/DownloadAndImportReplicator.java
index ee78a3c..cdab0fd 100644
--- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/DownloadAndImportReplicator.java
+++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/replication/DownloadAndImportReplicator.java
@@ -114,12 +114,8 @@ public class DownloadAndImportReplicator implements ContainerReplicator {
       //wait for the download. This thread pool is limiting the paralell
       //downloads, so it's ok to block here and wait for the full download.
       Path path = tempTarFile.get();
-      long bytes = Files.size(path);
-
-      LOG.info("Container {} is downloaded with size {}, starting to import.",
-          containerID, bytes);
-      task.setTransferredBytes(bytes);
-
+      LOG.info("Container {} is downloaded, starting to import.",
+          containerID);
       importContainer(containerID, path);
       LOG.info("Container {} is replicated successfully", containerID);
       task.setStatus(Status.DONE);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@ozone.apache.org
For additional commands, e-mail: commits-help@ozone.apache.org