diff --git a/remoting/getty/getty_client.go b/remoting/getty/getty_client.go
index 1d04d39eeb629416f1e4ed15143e7b767f9c3766..338478c603e955abee35dce3c46a971fabad2468 100644
--- a/remoting/getty/getty_client.go
+++ b/remoting/getty/getty_client.go
@@ -182,6 +182,7 @@ func (c *Client) Request(request *remoting.Request, timeout time.Duration, respo
 	)
 	if totalLen, sendLen, err = c.transfer(session, request, timeout); err != nil {
 		if sendLen != 0 && totalLen != sendLen {
+			logger.Warnf("start to close the session at request because %d of %d bytes data is sent success. err:%+v", sendLen, totalLen, err)
 			go c.Close()
 		}
 		return perrors.WithStack(err)
diff --git a/remoting/getty/listener.go b/remoting/getty/listener.go
index ac1b6749dbc04292b3be79418fed7bf26bc61f85..5443d371021c1235601a30a2e0011eeb9545713c 100644
--- a/remoting/getty/listener.go
+++ b/remoting/getty/listener.go
@@ -357,6 +357,7 @@ func (h *RpcServerHandler) OnCron(session getty.Session) {
 func reply(session getty.Session, resp *remoting.Response) {
 	if totalLen, sendLen, err := session.WritePkg(resp, WritePkg_Timeout); err != nil {
 		if sendLen != 0 && totalLen != sendLen {
+			logger.Warnf("start to close the session at replying because %d of %d bytes data is sent success. err:%+v", sendLen, totalLen, err)
 			go session.Close()
 		}
 		logger.Errorf("WritePkg error: %#v, %#v", perrors.WithStack(err), resp)
@@ -371,6 +372,7 @@ func heartbeat(session getty.Session, timeout time.Duration, callBack func(err e
 	remoting.AddPendingResponse(resp)
 	totalLen, sendLen, err := session.WritePkg(req, 3*time.Second)
 	if sendLen != 0 && totalLen != sendLen {
+		logger.Warnf("start to close the session at heartbeat because %d of %d bytes data is sent success. err:%+v", sendLen, totalLen, err)
 		go session.Close()
 	}