diff --git a/bigquery/benchmarks/bench.go b/bigquery/benchmarks/bench.go index 5aff71d1eea6..0e261950ea88 100644 --- a/bigquery/benchmarks/bench.go +++ b/bigquery/benchmarks/bench.go @@ -288,7 +288,7 @@ func main() { var createTable = flag.Bool("create_table", false, "create result table if it does not exist") var tags tags - flag.Var(&tags, "tag", "an optional key and value seperated by colon (:) character") + flag.Var(&tags, "tag", "an optional key and value separated by colon (:) character") flag.Parse() // Validate flags. diff --git a/bigquery/iterator.go b/bigquery/iterator.go index 8abf76aa1bf8..2cbcde029e6a 100644 --- a/bigquery/iterator.go +++ b/bigquery/iterator.go @@ -324,7 +324,7 @@ func fetchTableResultPage(ctx context.Context, src *rowSource, schema Schema, st } func fetchJobResultPage(ctx context.Context, src *rowSource, schema Schema, startIndex uint64, pageSize int64, pageToken string) (*fetchPageResult, error) { - // reduce data transfered by leveraging api projections + // reduce data transferred by leveraging api projections projectedFields := []googleapi.Field{"rows", "pageToken", "totalRows"} call := src.j.c.bqs.Jobs.GetQueryResults(src.j.projectID, src.j.jobID).Location(src.j.location).Context(ctx) call = call.FormatOptionsUseInt64Timestamp(true) diff --git a/bigquery/storage/managedwriter/connection.go b/bigquery/storage/managedwriter/connection.go index d8bbaee6bee4..6b46e535608b 100644 --- a/bigquery/storage/managedwriter/connection.go +++ b/bigquery/storage/managedwriter/connection.go @@ -357,7 +357,7 @@ func (co *connection) lockingAppend(pw *pendingWrite) error { // critical section: Things that need to happen inside the critical section: // - // * get/open conenction + // * get/open connection // * issue the append // * add the pending write to the channel for the connection (ordering for the response) co.mu.Lock() @@ -462,7 +462,7 @@ func (co *connection) lockingAppend(pw *pendingWrite) error { // getStream returns either a valid ARC client stream or permanent error. // -// Any calls to getStream should do so in possesion of the critical section lock. +// Any calls to getStream should do so in possession of the critical section lock. func (co *connection) getStream(arc *storagepb.BigQueryWrite_AppendRowsClient, forceReconnect bool) (*storagepb.BigQueryWrite_AppendRowsClient, chan *pendingWrite, error) { if co.err != nil { return nil, nil, co.err diff --git a/bigquery/storage/managedwriter/routers_test.go b/bigquery/storage/managedwriter/routers_test.go index f403e3671519..28f51203abbf 100644 --- a/bigquery/storage/managedwriter/routers_test.go +++ b/bigquery/storage/managedwriter/routers_test.go @@ -438,7 +438,7 @@ func BenchmarkWatchdogPulse(b *testing.B) { b.Fatalf("(@%d-@%d): activateRouter: %v", numWriters, numConnections, err) } // now, set router as multiplex. We do this to avoid router activation starting the watchdog - // in a seperate goroutine. + // in a separate goroutine. router.multiplex = true var writers []*ManagedStream