diff --git a/clientv3/integration/black_hole_test.go b/clientv3/integration/black_hole_test.go index 0ff3f73f1..68aa3c598 100644 --- a/clientv3/integration/black_hole_test.go +++ b/clientv3/integration/black_hole_test.go @@ -36,7 +36,7 @@ func TestBalancerUnderBlackholeKeepAliveWatch(t *testing.T) { clus := integration.NewClusterV3(t, &integration.ClusterConfig{ Size: 2, - GRPCKeepAliveMinTime: 1 * time.Millisecond, // avoid too_many_pings + GRPCKeepAliveMinTime: time.Millisecond, // avoid too_many_pings }) defer clus.Terminate(t) @@ -44,9 +44,9 @@ func TestBalancerUnderBlackholeKeepAliveWatch(t *testing.T) { ccfg := clientv3.Config{ Endpoints: []string{eps[0]}, - DialTimeout: 1 * time.Second, + DialTimeout: time.Second, DialOptions: []grpc.DialOption{grpc.WithBlock()}, - DialKeepAliveTime: 1 * time.Second, + DialKeepAliveTime: time.Second, DialKeepAliveTimeout: 500 * time.Millisecond, } @@ -72,6 +72,9 @@ func TestBalancerUnderBlackholeKeepAliveWatch(t *testing.T) { // endpoint can switch to eps[1] when it detects the failure of eps[0] cli.SetEndpoints(eps...) + // give enough time for balancer resolution + time.Sleep(5 * time.Second) + clus.Members[0].Blackhole() if _, err = clus.Client(1).Put(context.TODO(), "foo", "bar"); err != nil {