fix

jitsucom · Nov 27, 2023 · dcc6070 · dcc6070
1 parent 1101b20
commit dcc6070
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/bulkerlib/implementations/sql/redshift.go b/bulkerlib/implementations/sql/redshift.go
@@ -205,7 +205,7 @@ func (p *Redshift) CopyTables(ctx context.Context, targetTable *Table, sourceTab
 	quotedTargetTableName := p.quotedTableName(targetTable.Name)
 	quotedSourceTableName := p.quotedTableName(sourceTable.Name)
 
-	if mergeWindow <= 0 && len(targetTable.PKFields) > 0 {
+	if mergeWindow > 0 && len(targetTable.PKFields) > 0 {
 		//delete duplicates from table
 		var pkMatchConditions string
 		for i, pkColumn := range targetTable.GetPKFields() {