diff --git a/pkg/ccr/job.go b/pkg/ccr/job.go
index 40662962..f04e7aba 100644
--- 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