[clickhouse] Resync allow non deterministic mutations (#1935)

PeerDB-io · Jul 14, 2024 · e1977a8 · e1977a8
1 parent 0a353eb
commit e1977a8
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/flow/connectors/clickhouse/cdc.go b/flow/connectors/clickhouse/cdc.go
@@ -179,8 +179,9 @@ func (c *ClickhouseConnector) RenameTables(ctx context.Context, req *protos.Rena
 	for _, renameRequest := range req.RenameTableOptions {
 		if req.SyncedAtColName != "" {
 			syncedAtCol := strings.ToLower(req.SyncedAtColName)
-			_, err := c.execWithLogging(ctx, fmt.Sprintf("ALTER TABLE %s UPDATE %s=now() WHERE true",
-				renameRequest.CurrentName, syncedAtCol))
+			_, err := c.execWithLogging(ctx,
+				fmt.Sprintf("ALTER TABLE %s UPDATE %s=now() WHERE true SETTINGS allow_nondeterministic_mutations=1",
+					renameRequest.CurrentName, syncedAtCol))
 			if err != nil {
 				return nil, fmt.Errorf("unable to set synced at column for table %s: %w",
 					renameRequest.CurrentName, err)