You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ozone.apache.org by sa...@apache.org on 2021/11/24 01:49:44 UTC
[ozone] branch master updated: HDDS-5976. add raftlog IOException notifier for SCM HA (#2840)
This is an automated email from the ASF dual-hosted git repository.
sammichen 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 6372776 HDDS-5976. add raftlog IOException notifier for SCM HA (#2840)
6372776 is described below
commit 63727767313d4c2866b7eae514587d429b200f86
Author: Nibiru <ax...@qq.com>
AuthorDate: Wed Nov 24 09:49:25 2021 +0800
HDDS-5976. add raftlog IOException notifier for SCM HA (#2840)
---
.../main/java/org/apache/hadoop/hdds/scm/ha/SCMStateMachine.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SCMStateMachine.java b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SCMStateMachine.java
index 508593a..8fa1866 100644
--- a/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SCMStateMachine.java
+++ b/hadoop-hdds/server-scm/src/main/java/org/apache/hadoop/hdds/scm/ha/SCMStateMachine.java
@@ -176,6 +176,13 @@ public class SCMStateMachine extends BaseStateMachine {
}
@Override
+ public void notifyLogFailed(Throwable ex,
+ RaftProtos.LogEntryProto failedEntry) {
+ LOG.error("SCM statemachine appendLog failed, entry: {}", failedEntry);
+ ExitUtils.terminate(1, ex.getMessage(), ex, StateMachine.LOG);
+ }
+
+ @Override
public void notifyNotLeader(Collection<TransactionContext> pendingEntries) {
if (!isInitialized) {
return;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@ozone.apache.org
For additional commands, e-mail: commits-help@ozone.apache.org