From f007f1ecfcf555c13847b0c4e74fccf39f937be6 Mon Sep 17 00:00:00 2001
From: vaughn <vaughn@apache.org>
Date: Tue, 16 Sep 2025 10:14:55 +0800
Subject: [PATCH] improve: raft state machine should report error

---
 .../main/java/org/apache/hugegraph/pd/raft/RaftStateMachine.java | 1 +
 .../org/apache/hugegraph/store/raft/HgStoreStateMachine.java     | 1 +
 2 files changed, 2 insertions(+)

diff --git a/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftStateMachine.java b/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftStateMachine.java
index c7537d30a0..2df9241609 100644
--- a/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftStateMachine.java
+++ b/hugegraph-pd/hg-pd-core/src/main/java/org/apache/hugegraph/pd/raft/RaftStateMachine.java
@@ -94,6 +94,7 @@ public void onApply(Iterator iter) {
                 if (done != null) {
                     done.run(new Status(RaftError.EINTERNAL, t.getMessage()));
                 }
+                iter.setErrorAndRollback(1, new Status(RaftError.ESTATEMACHINE, t.getMessage()));
             }
             iter.next();
         }
diff --git a/hugegraph-store/hg-store-core/src/main/java/org/apache/hugegraph/store/raft/HgStoreStateMachine.java b/hugegraph-store/hg-store-core/src/main/java/org/apache/hugegraph/store/raft/HgStoreStateMachine.java
index 0f80017c53..f2560205df 100644
--- a/hugegraph-store/hg-store-core/src/main/java/org/apache/hugegraph/store/raft/HgStoreStateMachine.java
+++ b/hugegraph-store/hg-store-core/src/main/java/org/apache/hugegraph/store/raft/HgStoreStateMachine.java
@@ -101,6 +101,7 @@ public void onApply(Iterator inter) {
                               done.op.getReq());
                     //    done.run(new Status(RaftError.EINTERNAL, t.getMessage()));
                 }
+                inter.setErrorAndRollback(1, new Status(RaftError.ESTATEMACHINE, t.getMessage()));
             }
             committedIndex = inter.getIndex();