docs: correct typos present in docs/comments (#11145)

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.

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)

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

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