This is an automated email from the ASF dual-hosted git repository. nanda pushed a commit to branch HDDS-2823 in repository https://gitbox.apache.org/repos/asf/hadoop-ozone.git
commit d482abf62fa1ec72da8de0007535b82466a1be57 Author: Glen Geng <[email protected]> AuthorDate: Sat Oct 24 20:59:18 2020 +0530 HDDS-4125. Pipeline is not removed when a datanode goes stale. --- .../org/apache/hadoop/hdds/scm/pipeline/PipelineManagerV2Impl.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineManagerV2Impl.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineManagerV2Impl.java index 069540c..4690f29 100644 --- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineManagerV2Impl.java +++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineManagerV2Impl.java @@ -406,10 +406,7 @@ public final class PipelineManagerV2Impl implements PipelineManager { public void scrubPipeline(ReplicationType type, ReplicationFactor factor) throws IOException { checkLeader(); - if (type != ReplicationType.RATIS || factor != ReplicationFactor.THREE) { - // Only srub pipeline for RATIS THREE pipeline - return; - } + Instant currentTime = Instant.now(); Long pipelineScrubTimeoutInMills = conf.getTimeDuration( ScmConfigKeys.OZONE_SCM_PIPELINE_ALLOCATED_TIMEOUT, --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
