You are viewing a plain text version of this content. The canonical link for it is here.
Posted to hdfs-commits@hadoop.apache.org by el...@apache.org on 2019/10/13 06:51:43 UTC
[hadoop-ozone] 02/04: HDDS-1868. Set leaderId whenever available to
address leader re-election scenario.
This is an automated email from the ASF dual-hosted git repository.
elek pushed a commit to branch HDDS-1868
in repository https://gitbox.apache.org/repos/asf/hadoop-ozone.git
commit 73d072cd6749b71b46fba611c0d4340142814793
Author: Siddharth Wagle <sw...@hortonworks.com>
AuthorDate: Tue Oct 8 13:15:28 2019 -0700
HDDS-1868. Set leaderId whenever available to address leader re-election scenario.
---
.../org/apache/hadoop/hdds/scm/pipeline/PipelineReportHandler.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineReportHandler.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineReportHandler.java
index 10d40d9..a9534ca 100644
--- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineReportHandler.java
+++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/pipeline/PipelineReportHandler.java
@@ -113,6 +113,8 @@ public class PipelineReportHandler implements
reportedLeadersForPipeline.computeIfAbsent(pipelineID,
k -> new HashMap<>());
ids.put(dn.getUuid(), report.getLeaderID());
+ pipeline.setLeaderId(
+ RaftPeerId.valueOf(report.getLeaderID().toString()));
}
if (pipeline.getPipelineState() == Pipeline.PipelineState.ALLOCATED) {
@@ -124,8 +126,6 @@ public class PipelineReportHandler implements
leaderIdPairs.values().stream().distinct().count() == 1) {
// All datanodes reported same leader
pipelineManager.openPipeline(pipelineID);
- pipeline.setLeaderId(
- RaftPeerId.valueOf(report.getLeaderID().toString()));
}
} else {
// In OPEN state case just report the datanode
---------------------------------------------------------------------
To unsubscribe, e-mail: hdfs-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: hdfs-commits-help@hadoop.apache.org