diff --git a/dbswitch-data/src/main/java/com/gitee/dbswitch/data/handler/MigrationHandler.java b/dbswitch-data/src/main/java/com/gitee/dbswitch/data/handler/MigrationHandler.java
index 4ec50c32..55e66c82 100644
--- a/dbswitch-data/src/main/java/com/gitee/dbswitch/data/handler/MigrationHandler.java
+++ b/dbswitch-data/src/main/java/com/gitee/dbswitch/data/handler/MigrationHandler.java
@@ -436,7 +436,7 @@ public class MigrationHandler implements Supplier<Long> {
     }
 
     TaskParamEntity.TaskParamEntityBuilder taskBuilder = TaskParamEntity.builder();
-    taskBuilder.oldDataSource(this.sourceDataSource);
+    taskBuilder.oldDataSource(targetDataSource);
     taskBuilder.oldSchemaName(targetSchemaName);
     taskBuilder.oldTableName(targetTableName);
     taskBuilder.newDataSource(sourceDataSource);