From b4dbfa2be46f3134402f1dcfe1386111927a2429 Mon Sep 17 00:00:00 2001 From: Lloyd-Pottiger Date: Fri, 15 Mar 2024 16:22:29 +0800 Subject: [PATCH] fix return error Signed-off-by: Lloyd-Pottiger --- replicate/snapshot.go | 1 + 1 file changed, 1 insertion(+) diff --git a/replicate/snapshot.go b/replicate/snapshot.go index cbaa7c5..c593575 100644 --- 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()