Skip to content

Commit

Permalink
fix row copy
Browse files Browse the repository at this point in the history
  • Loading branch information
iskakaushik committed Feb 9, 2024
1 parent c174128 commit cf146bd
Showing 1 changed file with 13 additions and 6 deletions.
19 changes: 13 additions & 6 deletions flow/connectors/bigquery/bigquery.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ import (
"log/slog"
"reflect"
"regexp"
"slices"
"strings"
"time"

Expand Down Expand Up @@ -460,20 +461,26 @@ func (c *BigQueryConnector) getTableNametoUnchangedCols(flowJobName string, sync
// Create a map to store the results.
resultMap := make(map[string][]string)

// Process the query results using an iterator.
var row struct {
Tablename string `bigquery:"_peerdb_destination_table_name"`
UnchangedToastColumns []string `bigquery:"unchanged_toast_columns"`
}
for {
// Process the query results using an iterator.
var row struct {
Tablename string `bigquery:"_peerdb_destination_table_name"`
UnchangedToastColumns []string `bigquery:"unchanged_toast_columns"`
}

err := it.Next(&row)
if err == iterator.Done {
break
}
if err != nil {
return nil, err
}
resultMap[row.Tablename] = row.UnchangedToastColumns

resultMap[row.Tablename] = slices.Clone(row.UnchangedToastColumns)
c.logger.Info("unchanged toast columns",
slog.String("table", row.Tablename),
slog.Any("columns", row.UnchangedToastColumns),
)
}
return resultMap, nil
}
Expand Down

0 comments on commit cf146bd

Please sign in to comment.