[remove datanode] Not re-submit region migration procedure when leader change or reboot apache#14277

Author: liyuheng55555

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveDataNodesProcedure.java

@@ -133,7 +133,10 @@ protected Flow executeFromState(ConfigNodeProcedureEnv env, RemoveDataNodeState
           setNextState(RemoveDataNodeState.SUBMIT_REGION_MIGRATE);
           break;
         case SUBMIT_REGION_MIGRATE:
-          submitChildRegionMigrate(env);
+          // Avoid re-submit region-migration when leader change or ConfigNode reboot
+          if (!isStateDeserialized()) {
+            submitChildRegionMigrate(env);
+          }
           setNextState(RemoveDataNodeState.STOP_DATA_NODE);
           break;
         case STOP_DATA_NODE:
@@ -183,10 +186,10 @@ private void submitChildRegionMigrate(ConfigNodeProcedureEnv env) {
             LOG.info(
                 "Submit RegionMigrateProcedure for regionId {}: removedDataNode={}, destDataNode={}, coordinatorForAddPeer={}, coordinatorForRemovePeer={}",
                 regionId,
-                removedDataNode,
-                destDataNode,
-                coordinatorForAddPeer,
-                coordinatorForRemovePeer);
+                simplifyTDataNodeLocation(removedDataNode),
+                simplifyTDataNodeLocation(destDataNode),
+                simplifyTDataNodeLocation(coordinatorForAddPeer),
+                simplifyTDataNodeLocation(coordinatorForRemovePeer));
           } else {
             LOG.error(
                 "{}, Cannot find target DataNode to migrate the region: {}",
@@ -197,6 +200,12 @@ private void submitChildRegionMigrate(ConfigNodeProcedureEnv env) {
         });
   }
 
+  private String simplifyTDataNodeLocation(TDataNodeLocation dataNodeLocation) {
+    return String.format(
+        "DataNode(id:%d, address:%s)",
+        dataNodeLocation.getDataNodeId(), dataNodeLocation.getInternalEndPoint().getIp());
+  }
+
   private void checkRegionStatusAndStopDataNode(ConfigNodeProcedureEnv env) {
     List<TRegionReplicaSet> replicaSets =
         env.getConfigManager().getPartitionManager().getAllReplicaSets();