diff --git a/bigquery/storage/managedwriter/integration_test.go b/bigquery/storage/managedwriter/integration_test.go index 48b536fb3cbd..e13439afa664 100644 --- a/bigquery/storage/managedwriter/integration_test.go +++ b/bigquery/storage/managedwriter/integration_test.go @@ -1498,6 +1498,7 @@ func TestIntegration_MultiplexWrites(t *testing.T) { WithDestinationTable(TableParentFromParts(testTable.tbl.ProjectID, testTable.tbl.DatasetID, testTable.tbl.TableID)), WithType(DefaultStream), WithSchemaDescriptor(testTable.dp), + EnableWriteRetries(true), ) if err != nil { t.Fatalf("NewManagedStream %d: %v", k, err)