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 c8e6cabc8f HDDS-10345. No need to sort excluded datanodes during Ratis
pipeline creation (#6224)
c8e6cabc8f is described below
commit c8e6cabc8f0edb6183dd09a302570ba7480a9b87
Author: Siddhant Sangwan <[email protected]>
AuthorDate: Tue Feb 20 12:56:43 2024 +0530
HDDS-10345. No need to sort excluded datanodes during Ratis pipeline
creation (#6224)
---
.../java/org/apache/hadoop/hdds/scm/pipeline/RatisPipelineProvider.java | 2 --
1 file changed, 2 deletions(-)
diff --git
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/RatisPipelineProvider.java
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/RatisPipelineProvider.java
index 8336bce5ea..163f423510 100644
---
a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/RatisPipelineProvider.java
+++
b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/RatisPipelineProvider.java
@@ -20,7 +20,6 @@ package org.apache.hadoop.hdds.scm.pipeline;
import java.io.IOException;
import java.util.Collections;
-import java.util.Comparator;
import java.util.List;
import java.util.Set;
import java.util.stream.Collectors;
@@ -244,7 +243,6 @@ public class RatisPipelineProvider
getPipelineStateManager(), d)))
.filter(d ->
(d.getPipelines() >= getNodeManager().pipelineLimit(d.getDn())))
- .sorted(Comparator.comparingInt(DnWithPipelines::getPipelines))
.map(d -> d.getDn())
.collect(Collectors.toList());
return excluded;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
