You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by sh...@apache.org on 2020/07/14 03:59:14 UTC
[hadoop-ozone] branch master updated: HDDS-3861. Fix
handlePipelineFailure throw exception if role is follower (#1122)
This is an automated email from the ASF dual-hosted git repository.
shashikant pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hadoop-ozone.git
The following commit(s) were added to refs/heads/master by this push:
new 537172e HDDS-3861. Fix handlePipelineFailure throw exception if role is follower (#1122)
537172e is described below
commit 537172ee2cdb343359082dfc0c23c01068d4f24e
Author: runzhiwang <51...@users.noreply.github.com>
AuthorDate: Tue Jul 14 11:59:03 2020 +0800
HDDS-3861. Fix handlePipelineFailure throw exception if role is follower (#1122)
---
.../common/transport/server/ratis/XceiverServerRatis.java | 8 ++++++++
1 file changed, 8 insertions(+)
diff --git a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/XceiverServerRatis.java b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/XceiverServerRatis.java
index 6c98e81..3e6ac10 100644
--- a/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/XceiverServerRatis.java
+++ b/hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/XceiverServerRatis.java
@@ -552,6 +552,14 @@ public final class XceiverServerRatis implements XceiverServerSpi {
msg = datanode + " is in candidate state for " +
roleInfoProto.getCandidateInfo().getLastLeaderElapsedTimeMs() + "ms";
break;
+ case FOLLOWER:
+ msg = datanode + " closes pipeline when installSnapshot from leader " +
+ "because leader snapshot doesn't contain any data to replay, " +
+ "all the log entries prior to the snapshot might have been purged." +
+ "So follower should not try to install snapshot from leader but" +
+ "can close the pipeline here. It's in follower state for " +
+ roleInfoProto.getRoleElapsedTimeMs() + "ms";
+ break;
case LEADER:
StringBuilder sb = new StringBuilder();
sb.append(datanode).append(" has not seen follower/s");
---------------------------------------------------------------------
To unsubscribe, e-mail: ozone-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: ozone-commits-help@hadoop.apache.org