fix return error

Signed-off-by: Lloyd-Pottiger <yan1579196623@gmail.com>
pingcap-inc · Mar 15, 2024 · b4dbfa2 · b4dbfa2
1 parent 6cfbd2c
commit b4dbfa2
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/replicate/snapshot.go b/replicate/snapshot.go
@@ -151,6 +151,7 @@ func (sess *SnapshotReplicateSession) Run() error {
 	} else {
 		if err := sess.DataWarehousePool.LoadSnapshot(sess.SourceTable, fmt.Sprintf("%s.%s.*", sess.SourceDatabase, sess.SourceTable)); err != nil {
 			sess.logger.Error("Failed to load snapshot data into data warehouse", zap.Error(err))
+			return errors.Trace(err)
 		}
 	}
 	endTime := time.Now()