diff --git a/fe/src/main/java/org/apache/doris/alter/SchemaChangeJob.java b/fe/src/main/java/org/apache/doris/alter/SchemaChangeJob.java
index 5dbdfd55c7..e890edf421 100644
--- a/fe/src/main/java/org/apache/doris/alter/SchemaChangeJob.java
+++ b/fe/src/main/java/org/apache/doris/alter/SchemaChangeJob.java
@@ -432,7 +432,7 @@ public class SchemaChangeJob extends AlterJob {
                                     // but in case some edge cases are not took into consideration, we cancel
                                     // the schema change job here.
                                     cancelMsg = String.format(
-                                            "replica %d of tablet %d in backend %d state is invalid: %s",
+                                            "replica %d of tablet %d in backend %d state is invalid: %s [send]",
                                             replica.getId(), tablet.getId(), replica.getBackendId(),
                                             replica.getState().name());
                                     LOG.warn(cancelMsg);
@@ -688,7 +688,7 @@ public class SchemaChangeJob extends AlterJob {
                                 if (replica.getState() != ReplicaState.SCHEMA_CHANGE) {
                                     // all replicas should be in state SCHEMA_CHANGE
                                     cancelMsg = String.format(
-                                            "replica %d of tablet %d in backend %d state is invalid: %s",
+                                            "replica %d of tablet %d in backend %d state is invalid: %s [try finish]",
                                             replica.getId(), tablet.getId(), replica.getBackendId(),
                                             replica.getState().name());
                                     LOG.warn(cancelMsg);
@@ -793,7 +793,7 @@ public class SchemaChangeJob extends AlterJob {
                                 if (replica.getState() != ReplicaState.SCHEMA_CHANGE) {
                                     // all replicas should be in state SCHEMA_CHANGE
                                     cancelMsg = String.format(
-                                            "replica %d of tablet %d in backend %d state is invalid: %s",
+                                            "replica %d of tablet %d in backend %d state is invalid: %s [finish]",
                                             replica.getId(), tablet.getId(), replica.getBackendId(),
                                             replica.getState().name());
                                     LOG.warn(cancelMsg);
diff --git a/fe/src/main/java/org/apache/doris/clone/TabletSchedCtx.java b/fe/src/main/java/org/apache/doris/clone/TabletSchedCtx.java
index 02bea58e55..a444c18aa5 100644
--- a/fe/src/main/java/org/apache/doris/clone/TabletSchedCtx.java
+++ b/fe/src/main/java/org/apache/doris/clone/TabletSchedCtx.java
@@ -601,16 +601,30 @@ public class TabletSchedCtx implements Comparable<TabletSchedCtx> {
                 visibleVersion, visibleVersionHash);
         cloneTask.setPathHash(srcPathHash, destPathHash);
         
-        Replica cloneReplica = new Replica(
-                Catalog.getCurrentCatalog().getNextId(), destBackendId,
-                -1 /* version */, 0 /* version hash */, schemaHash,
-                -1 /* data size */, -1 /* row count */,
-                ReplicaState.CLONE,
-                committedVersion, committedVersionHash, /* use committed version as last failed version */
-                -1 /* last success version */, 0 /* last success version hash */);
-        
-        // addReplica() method will add this replica to tablet inverted index too.
-        tablet.addReplica(cloneReplica);
+        if (tabletStatus == TabletStatus.REPLICA_MISSING || tabletStatus == TabletStatus.REPLICA_MISSING_IN_CLUSTER) {
+            // only these 2 status need to create a new replica.
+            Replica cloneReplica = new Replica(
+                    Catalog.getCurrentCatalog().getNextId(), destBackendId,
+                    -1 /* version */, 0 /* version hash */, schemaHash,
+                    -1 /* data size */, -1 /* row count */,
+                    ReplicaState.CLONE,
+                    committedVersion, committedVersionHash, /* use committed version as last failed version */
+                    -1 /* last success version */, 0 /* last success version hash */);
+
+            // addReplica() method will add this replica to tablet inverted index too.
+            tablet.addReplica(cloneReplica);
+        } else if (tabletStatus == TabletStatus.VERSION_INCOMPLETE) {
+            // double check
+            Replica replica = tablet.getReplicaByBackendId(destBackendId);
+            if (replica == null) {
+                throw new SchedException(Status.SCHEDULE_FAILED, "dest replica does not exist on BE " + destBackendId);
+            }
+
+            if (replica.getPathHash() != destPathHash) {
+                throw new SchedException(Status.SCHEDULE_FAILED, "dest replica's path hash is changed. "
+                        + "current: " + replica.getPathHash() + ", scheduled: " + destPathHash);
+            }
+        }
         
         taskTimeoutMs = getApproximateTimeoutMs();