diff --git a/flow/connectors/clickhouse/cdc.go b/flow/connectors/clickhouse/cdc.go index 737d080ff1..4a7dd98013 100644 --- 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)