update

Author: Ryan19929

pkg/ccr/job.go

@@ -1018,24 +1018,17 @@ func (j *Job) fullSync() error {
 			}
 
 			if !tableExists {
-				// Table has been dropped during full sync
+				// Table has been dropped during full sync, wait for recreate (regardless of feature flag)
+				// TableDroppedFlag already set by checkTableExistsForTableSync
 				if featureResyncOnTableRecreate {
-					// Wait for table to be recreated (TableDroppedFlag already set by checkTableExistsForTableSync)
 					log.Warnf("table %s.%s has been dropped during full sync, waiting for recreate",
 						j.Src.Database, j.Src.Table)
-					return nil
 				} else {
-					// Pause job
-					msg := fmt.Sprintf("table %s.%s has been dropped during full sync. Job will be paused.",
+					log.Warnf("table %s.%s has been dropped during full sync. Auto-resync disabled, waiting and retry. "+
+						"Enable with: -feature_resync_on_table_recreate=true",
 						j.Src.Database, j.Src.Table)
-					log.Warnf(msg)
-					j.progress.SetFullSyncInfo(msg)
-					j.progress.Persist()
-					if err := j.Pause(); err != nil {
-						log.Errorf("failed to pause job: %+v", err)
-					}
-					return xerror.Errorf(xerror.Normal, msg)
 				}
+				return nil
 			}
 
 			// Step 1.2.2: Check if table_id changed again (table dropped and recreated during full sync)