diff --git a/saga/seata-saga-engine/src/main/java/org/apache/seata/saga/engine/impl/ProcessCtrlStateMachineEngine.java b/saga/seata-saga-engine/src/main/java/org/apache/seata/saga/engine/impl/ProcessCtrlStateMachineEngine.java
index 9d05f5e2749..d18e72f8be8 100644
--- a/saga/seata-saga-engine/src/main/java/org/apache/seata/saga/engine/impl/ProcessCtrlStateMachineEngine.java
+++ b/saga/seata-saga-engine/src/main/java/org/apache/seata/saga/engine/impl/ProcessCtrlStateMachineEngine.java
@@ -263,7 +263,7 @@ protected StateMachineInstance forwardInternal(String stateMachineInstId, Map<St
         if (replaceParams != null) {
             contextVariables.putAll(replaceParams);
         }
-        putBusinesskeyToContextariables(stateMachineInstance, contextVariables);
+        putBusinessKeyToContextVariables(stateMachineInstance, contextVariables);
 
         ConcurrentHashMap<String, Object> concurrentContextVariables = new ConcurrentHashMap<>(contextVariables.size());
         nullSafeCopy(contextVariables, concurrentContextVariables);
@@ -508,7 +508,7 @@ public StateMachineInstance compensateInternal(String stateMachineInstId, Map<St
         if (replaceParams != null) {
             contextVariables.putAll(replaceParams);
         }
-        putBusinesskeyToContextariables(stateMachineInstance, contextVariables);
+        putBusinessKeyToContextVariables(stateMachineInstance, contextVariables);
 
         ConcurrentHashMap<String, Object> concurrentContextVariables = new ConcurrentHashMap<>(contextVariables.size());
         nullSafeCopy(contextVariables, concurrentContextVariables);
@@ -696,7 +696,7 @@ private String buildExceptionMessage(StateMachineInstance stateMachineInstance,
         return stringBuilder.toString();
     }
 
-    private void putBusinesskeyToContextariables(StateMachineInstance stateMachineInstance,
+    private void putBusinessKeyToContextVariables(StateMachineInstance stateMachineInstance,
                                                  Map<String, Object> contextVariables) {
         if (StringUtils.hasText(stateMachineInstance.getBusinessKey()) && !contextVariables.containsKey(
             DomainConstants.VAR_NAME_BUSINESSKEY)) {
diff --git a/saga/seata-saga-statelang/src/main/java/org/apache/seata/saga/statelang/parser/utils/DesignerJsonTransformer.java b/saga/seata-saga-statelang/src/main/java/org/apache/seata/saga/statelang/parser/utils/DesignerJsonTransformer.java
index d653b6708ae..7a69c8b5c25 100644
--- a/saga/seata-saga-statelang/src/main/java/org/apache/seata/saga/statelang/parser/utils/DesignerJsonTransformer.java
+++ b/saga/seata-saga-statelang/src/main/java/org/apache/seata/saga/statelang/parser/utils/DesignerJsonTransformer.java
@@ -122,7 +122,7 @@ private static void transformEdge(Map<String, Object> machineJsonObject, List<Ob
                     machineJsonObject.put("StartState", targetStateId);
                     //Make sure 'StartState' is before 'States'
                     machineJsonObject.put("States", machineJsonObject.remove("States"));
-                } else if ("ServiceTask".equals(sourceType)) {
+                } else if ("ServiceTask".equals(sourceType) || "SubStateMachine".equals(sourceType)) {
                     if (targetNode != null && "Compensation".equals(targetNode.get("stateType"))) {
                         sourceState.put("CompensateState", targetStateId);
                     } else {