Merge branch 'main' into generic-test

PeerDB-io · Mar 6, 2024 · badda72 · badda72
2 parents a2e2214 + 373bfb2
commit badda72
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/flow/connectors/clickhouse/qrep_avro_sync.go b/flow/connectors/clickhouse/qrep_avro_sync.go
@@ -130,12 +130,12 @@ func (s *ClickhouseAvroSyncMethod) SyncQRepRecords(
 			continue
 		}
 
-		selector = append(selector, colName)
+		selector = append(selector, "`"+colName+"`")
 	}
 	selectorStr := strings.Join(selector, ",")
 	//nolint:gosec
-	query := fmt.Sprintf("INSERT INTO %s(%s) SELECT * FROM s3('%s','%s','%s', 'Avro')",
-		config.DestinationTableIdentifier, selectorStr, avroFileUrl,
+	query := fmt.Sprintf("INSERT INTO %s(%s) SELECT %s FROM s3('%s','%s','%s', 'Avro')",
+		config.DestinationTableIdentifier, selectorStr, selectorStr, avroFileUrl,
 		s.connector.creds.AccessKeyID, s.connector.creds.SecretAccessKey)
 
 	_, err = s.connector.database.ExecContext(ctx, query)