Update comments in functions

go/vt/binlog/binlogplayertest/player.go

@@ -96,7 +96,7 @@ var testBinlogTransaction = &binlogdatapb.BinlogTransaction{
 	},
 }
 
-// StreamKeyRange is part of the the UpdateStream interface
+// StreamKeyRange is part of the UpdateStream interface
 func (fake *FakeBinlogStreamer) StreamKeyRange(ctx context.Context, position string, keyRange *topodatapb.KeyRange, charset *binlogdatapb.Charset, callback func(reply *binlogdatapb.BinlogTransaction) error) error {
 	if fake.panics {
 		panic(fmt.Errorf("test-triggered panic"))
@@ -162,7 +162,7 @@ var testTablesRequest = &tablesRequest{
 	},
 }
 
-// StreamTables is part of the the UpdateStream interface
+// StreamTables is part of the UpdateStream interface
 func (fake *FakeBinlogStreamer) StreamTables(ctx context.Context, position string, tables []string, charset *binlogdatapb.Charset, callback func(reply *binlogdatapb.BinlogTransaction) error) error {
 	if fake.panics {
 		panic(fmt.Errorf("test-triggered panic"))
@@ -214,7 +214,7 @@ func testStreamTablesPanics(t *testing.T, bpc binlogplayer.Client) {
 	}
 }
 
-// HandlePanic is part of the the UpdateStream interface
+// HandlePanic is part of the UpdateStream interface
 func (fake *FakeBinlogStreamer) HandlePanic(err *error) {
 	if x := recover(); x != nil {
 		*err = fmt.Errorf("Caught panic: %v", x)

go/vt/schemamanager/schemaswap/schema_swap.go

@@ -459,7 +459,7 @@ func (schemaSwap *Swap) stopAllHealthWatchers() {
 }
 
 // initializeSwap starts the schema swap process. If there is already a schema swap process started
-// the the method just picks up that. Otherwise it starts a new one and writes into the database that
+// the method just picks up that. Otherwise it starts a new one and writes into the database that
 // the process was started.
 func (schemaSwap *Swap) initializeSwap() error {
 	var waitGroup sync.WaitGroup

go/vt/vtgate/planbuilder/insert.go

@@ -206,7 +206,7 @@ func modifyForAutoinc(ins *sqlparser.Insert, eins *engine.Insert) error {
 	return nil
 }
 
-// swapBindVariables swaps in bind variable names at the the specified
+// swapBindVariables swaps in bind variable names at the specified
 // column position in the AST values and returns the converted values back.
 // Bind variable names are generated using baseName.
 func swapBindVariables(rows sqlparser.Values, colNum int, baseName string) (sqltypes.PlanValue, error) {

go/vt/vtgate/planbuilder/ordered_aggregate.go

@@ -272,7 +272,7 @@ func (oa *orderedAggregate) PushFilter(_ *primitiveBuilder, _ sqlparser.Expr, wh
 // be performed 'as they come'. In this respect, oa is the originator for
 // aggregate expressions like MAX, which will be added to symtab. The underlying
 // MAX sent to the route will not be added to symtab and will not be reachable by
-// others. This functionality depends on the the PushOrderBy to request that
+// others. This functionality depends on the PushOrderBy to request that
 // the rows be correctly ordered for a merge sort.
 func (oa *orderedAggregate) PushSelect(expr *sqlparser.AliasedExpr, origin builder) (rc *resultColumn, colnum int, err error) {
 	if inner, ok := expr.Expr.(*sqlparser.FuncExpr); ok {

go/vt/vtgate/scatter_conn.go

@@ -700,7 +700,7 @@ func injectShuffleQueryPartsRandomGenerator(
 	return oldRandGen
 }
 
-// shuffleQueryParts performs an in-place shuffle of the the given array.
+// shuffleQueryParts performs an in-place shuffle of the given array.
 // The result is a psuedo-random permutation of the array chosen uniformally
 // from the space of all permutations.
 func shuffleQueryParts(splits []*vtgatepb.SplitQueryResponse_Part) {