filter dropped table when restore (#115)

Co-authored-by: walter <[email protected]>
selectdb · Jun 14, 2024 · b0b9290 · b0b9290
1 parent 5286e32
commit b0b9290
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/pkg/ccr/job.go b/pkg/ccr/job.go
@@ -489,6 +489,13 @@ func (j *Job) fullSync() error {
 					return err
 				}
 
+				// If srcTableName is empty, it may be deleted.
+				// No need to map it to dest table
+				if srcTableName == "" {
+					log.Warnf("the name of source table id: %d is empty, no need to map it to dest table", srcTableId)
+					continue
+				}
+
 				destTableId, err := j.destMeta.GetTableId(srcTableName)
 				if err != nil {
 					return err