This is an automated email from the ASF dual-hosted git repository.
licheng pushed a commit to branch HDDS-2823
in repository https://gitbox.apache.org/repos/asf/hadoop-ozone.git
The following commit(s) were added to refs/heads/HDDS-2823 by this push:
new fb32aa7 HDDS-4125: Pipeline is not removed when a datanode goes stale
(#1334)
fb32aa7 is described below
commit fb32aa79b4734b5d350b933cb1ba12c7cbe13c06
Author: GlenGeng <[email protected]>
AuthorDate: Tue Aug 18 17:30:57 2020 +0800
HDDS-4125: Pipeline is not removed when a datanode goes stale (#1334)
---
.../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 466664f..b462bc2 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
@@ -416,10 +416,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]
