This is an automated email from the ASF dual-hosted git repository. vaughn pushed a commit to branch feat_sailuo in repository https://gitbox.apache.org/repos/asf/incubator-hugegraph.git
commit f007f1ecfcf555c13847b0c4e74fccf39f937be6 Author: vaughn <[email protected]> AuthorDate: Tue Sep 16 10:14:55 2025 +0800 improve: raft state machine should report error --- .../src/main/java/org/apache/hugegraph/pd/raft/RaftStateMachine.java | 1 + .../main/java/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 c7537d30a..2df924160 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 class RaftStateMachine extends StateMachineAdapter { 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 0f80017c5..f2560205d 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 class HgStoreStateMachine extends StateMachineAdapter { done.op.getReq()); // done.run(new Status(RaftError.EINTERNAL, t.getMessage())); } + inter.setErrorAndRollback(1, new Status(RaftError.ESTATEMACHINE, t.getMessage())); } committedIndex = inter.getIndex();
