Disable clean tables & partitions by default (#161)

selectdb · Sep 10, 2024 · 6ab94ff · 6ab94ff
1 parent 50d3058
commit 6ab94ff
Showing 1 changed file with 5 additions and 6 deletions.
diff --git a/pkg/ccr/job.go b/pkg/ccr/job.go
@@ -672,13 +672,12 @@ func (j *Job) fullSync() error {
 		}
 
 		// drop exists partitions, and drop tables if in db sync.
-		cleanTables, cleanPartitions := false, true
-		if j.SyncType == DBSync {
-			cleanTables = true
-		}
+		cleanTables, cleanPartitions := false, false
 		if featureCleanTableAndPartitions {
-			cleanTables = false
-			cleanPartitions = false
+			cleanPartitions = true
+			if j.SyncType == DBSync {
+				cleanTables = true
+			}
 		}
 		restoreResp, err := destRpc.RestoreSnapshot(dest, tableRefs, restoreSnapshotName, snapshotResp, cleanTables, cleanPartitions)
 		if err != nil {