chore: remove repetitive words

balancer/leastrequest/balancer_test.go

@@ -170,7 +170,7 @@ func checkRoundRobinRPCs(ctx context.Context, client testgrpc.TestServiceClient,
 			}
 			iterations = append(iterations, iteration)
 		}
-		// Ensure the the first iteration contains all addresses in addrs.
+		// Ensure the first iteration contains all addresses in addrs.
 		for _, addr := range iterations[0] {
 			gotAddrCount[addr]++
 		}

balancer/weightedroundrobin/scheduler.go

@@ -125,7 +125,7 @@ func (s *edfScheduler) nextIndex() int {
 }
 
 // A simple RR scheduler to use for fallback when fewer than two backends have
-// non-zero weights, or all backends have the the same weight, or when only one
+// non-zero weights, or all backends have the same weight, or when only one
 // subconn exists.
 type rrScheduler struct {
 	inc    func() uint32

clientconn.go

@@ -67,7 +67,7 @@ var (
 	errConnDrain = errors.New("grpc: the connection is drained")
 	// errConnClosing indicates that the connection is closing.
 	errConnClosing = errors.New("grpc: the connection is closing")
-	// errConnIdling indicates the the connection is being closed as the channel
+	// errConnIdling indicates the connection is being closed as the channel
 	// is moving to an idle mode due to inactivity.
 	errConnIdling = errors.New("grpc: the connection is closing due to channel idleness")
 	// invalidDefaultServiceConfigErrPrefix is used to prefix the json parsing error for the default

examples/features/observability/client/main.go

@@ -43,7 +43,7 @@ var (
 func main() {
 	// Turn on global telemetry for the whole binary. If a configuration is
 	// specified, any created gRPC Client Conn's or Servers will emit telemetry
-	// data according the the configuration.
+	// data according the configuration.
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
 	defer cancel()
 	err := observability.Start(ctx)

examples/features/observability/server/main.go

@@ -53,7 +53,7 @@ func (s *server) SayHello(ctx context.Context, in *pb.HelloRequest) (*pb.HelloRe
 func main() {
 	// Turn on global telemetry for the whole binary. If a configuration is
 	// specified, any created gRPC Client Conn's or Servers will emit telemetry
-	// data according the the configuration.
+	// data according the configuration.
 	ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
 	defer cancel()
 	err := observability.Start(ctx)

test/authority_test.go

@@ -210,7 +210,7 @@ func (s) TestColonPortAuthority(t *testing.T) {
 }
 
 // TestAuthorityReplacedWithResolverAddress tests the scenario where the resolver
-// returned address contains a ServerName override. The test verifies that the the
+// returned address contains a ServerName override. The test verifies that the
 // :authority header value sent to the server as part of the http/2 HEADERS frame
 // is set to the value specified in the resolver returned address.
 func (s) TestAuthorityReplacedWithResolverAddress(t *testing.T) {

test/xds/xds_client_outlier_detection_test.go

@@ -136,7 +136,7 @@ func checkRoundRobinRPCs(ctx context.Context, client testgrpc.TestServiceClient,
 			}
 			iterations = append(iterations, iteration)
 		}
-		// Ensure the the first iteration contains all addresses in addrs.
+		// Ensure the first iteration contains all addresses in addrs.
 		gotAddrCount := make(map[string]int)
 		for _, addr := range iterations[0] {
 			gotAddrCount[addr]++

xds/internal/balancer/outlierdetection/e2e_test/outlierdetection_test.go

@@ -123,7 +123,7 @@ func checkRoundRobinRPCs(ctx context.Context, client testgrpc.TestServiceClient,
 			}
 			iterations = append(iterations, iteration)
 		}
-		// Ensure the the first iteration contains all addresses in addrs.
+		// Ensure the first iteration contains all addresses in addrs.
 		for _, addr := range iterations[0] {
 			gotAddrCount[addr]++
 		}