diff --git a/domain/domain.go b/domain/domain.go index 4810114cefc58..beaf9a9f25d54 100644 --- a/domain/domain.go +++ b/domain/domain.go @@ -619,9 +619,8 @@ func (do *Domain) Init(ddlLease time.Duration, sysFactory func(*Domain) (pools.R DialOptions: []grpc.DialOption{ grpc.WithBackoffMaxDelay(time.Second * 3), grpc.WithKeepaliveParams(keepalive.ClientParameters{ - Time: time.Duration(cfg.TiKVClient.GrpcKeepAliveTime) * time.Second, - Timeout: time.Duration(cfg.TiKVClient.GrpcKeepAliveTimeout) * time.Second, - PermitWithoutStream: true, + Time: time.Duration(cfg.TiKVClient.GrpcKeepAliveTime) * time.Second, + Timeout: time.Duration(cfg.TiKVClient.GrpcKeepAliveTimeout) * time.Second, }), }, TLS: ebd.TLSConfig(), diff --git a/store/tikv/kv.go b/store/tikv/kv.go index 751c2d4d0028a..07efb681dbd02 100755 --- a/store/tikv/kv.go +++ b/store/tikv/kv.go @@ -85,9 +85,8 @@ func (d Driver) Open(path string) (kv.Storage, error) { KeyPath: security.ClusterSSLKey, }, pd.WithGRPCDialOptions( grpc.WithKeepaliveParams(keepalive.ClientParameters{ - Time: time.Duration(tikvConfig.GrpcKeepAliveTime) * time.Second, - Timeout: time.Duration(tikvConfig.GrpcKeepAliveTimeout) * time.Second, - PermitWithoutStream: true, + Time: time.Duration(tikvConfig.GrpcKeepAliveTime) * time.Second, + Timeout: time.Duration(tikvConfig.GrpcKeepAliveTimeout) * time.Second, }), ))