diff --git a/tests/integration/clientv3/naming/resolver_test.go b/tests/integration/clientv3/naming/resolver_test.go index b64acf9a802..3242d03f5d4 100644 --- a/tests/integration/clientv3/naming/resolver_test.go +++ b/tests/integration/clientv3/naming/resolver_test.go @@ -93,7 +93,7 @@ func testEtcdGrpcResolver(t *testing.T, lbPolicy string) { // Send more requests lastResponse := []byte{'1'} - totalRequests := 1000 + totalRequests := 3500 for i := 1; i < totalRequests; i++ { resp, err := c.UnaryCall(context.TODO(), &testpb.SimpleRequest{}, grpc.WaitForReady(true)) if err != nil { @@ -111,7 +111,7 @@ func testEtcdGrpcResolver(t *testing.T, lbPolicy string) { // If the load balancing policy is pick first then return payload should equal number of requests t.Logf("Last response: %v", string(lastResponse)) if lbPolicy == "pick_first" { - if string(lastResponse) != "1000" { + if string(lastResponse) != "3500" { t.Fatalf("unexpected total responses from foo: %s", string(lastResponse)) } }