fix drop table where restore

selectdb · Jun 14, 2024 · 979c500 · 979c500
1 parent 5286e32
commit 979c500
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/ccr/job.go b/pkg/ccr/job.go
@@ -489,6 +489,12 @@ func (j *Job) fullSync() error {
 					return err
 				}
 
+				// If srcTableName is empty, it may be deleted.
+				// No need to mapping it to dest table
+				if srcTableName == "" {
+					continue
+				}
+
 				destTableId, err := j.destMeta.GetTableId(srcTableName)
 				if err != nil {
 					return err