diff --git a/pkg/remoting/getty/rpc_client.go b/pkg/remoting/getty/rpc_client.go index ffd769e78..557b010f8 100644 --- a/pkg/remoting/getty/rpc_client.go +++ b/pkg/remoting/getty/rpc_client.go @@ -140,6 +140,6 @@ func (c *RpcClient) setSessionConfig(session getty.Session) { session.SetEventListener(GetGettyClientHandlerInstance()) session.SetReadTimeout(c.gettyConf.SessionConfig.TCPReadTimeout) session.SetWriteTimeout(c.gettyConf.SessionConfig.TCPWriteTimeout) - session.SetCronPeriod((int)(c.gettyConf.SessionConfig.CronPeriod.Milliseconds())) + session.SetCronPeriod((int)(c.gettyConf.SessionConfig.CronPeriod.Nanoseconds() / 1e6)) session.SetWaitTime(c.gettyConf.SessionConfig.WaitTimeout) } diff --git a/sample/conf/seatago.yml b/sample/conf/seatago.yml index 2024cf272..9beb8b55c 100644 --- a/sample/conf/seatago.yml +++ b/sample/conf/seatago.yml @@ -143,7 +143,7 @@ seata: # getty configuration getty: reconnect-interval: 0 - connection-num: 16 + connection-num: 1 heartbeat-period: 15s session: compress-encoding: false @@ -152,7 +152,7 @@ seata: keep-alive-period: 120s tcp-r-buf-size: 262144 tcp-w-buf-size: 65536 - tcp-read-timeout: 1s + tcp-read-timeout: 5s tcp-write-timeout: 5s wait-timeout: 1s max-msg-len: 16498688