bigquery: fix load snapshot failed when the table is big (#87)

Signed-off-by: Lloyd-Pottiger <yan1579196623@gmail.com>
pingcap-inc · Jan 17, 2024 · c8d4c63 · c8d4c63
1 parent 258b0f3
commit c8d4c63
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/bigquerysql/operation.go b/pkg/bigquerysql/operation.go
@@ -37,7 +37,7 @@ func loadGCSFileToBigQuery(ctx context.Context, client *bigquery.Client, dataset
 	gcsRef.NullMarker = "\\N"
 
 	loader := client.Dataset(datasetID).Table(tableID).LoaderFrom(gcsRef)
-	loader.WriteDisposition = bigquery.WriteEmpty
+	loader.WriteDisposition = bigquery.WriteAppend
 
 	job, err := loader.Run(ctx)
 	if err != nil {