diff --git a/rpc/http.go b/rpc/http.go index 32f4e7d90a259..8640fb8898826 100644 --- a/rpc/http.go +++ b/rpc/http.go @@ -174,6 +174,7 @@ func (hc *httpConn) doRequest(ctx context.Context, msg interface{}) (io.ReadClos return nil, err } req.ContentLength = int64(len(body)) + req.GetBody = func() (io.ReadCloser, error) { return ioutil.NopCloser(bytes.NewReader(body)), nil } // set headers hc.mu.Lock()