File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -40,7 +40,7 @@ import (
40
40
const (
41
41
DefaultTimeZone = "Asia/Shanghai"
42
42
DefaultFetchSize = 1024
43
- DefualtConnectRetryMax = 3
43
+ DefaultConnectRetryMax = 3
44
44
)
45
45
46
46
var errLength = errors .New ("deviceIds, times, measurementsList and valuesList's size should be equal" )
@@ -79,7 +79,7 @@ func (s *Session) Open(enableRPCCompression bool, connectionTimeoutInMs int) err
79
79
}
80
80
81
81
if s .config .ConnectRetryMax <= 0 {
82
- s .config .ConnectRetryMax = DefualtConnectRetryMax
82
+ s .config .ConnectRetryMax = DefaultConnectRetryMax
83
83
}
84
84
85
85
var protocolFactory thrift.TProtocolFactory
@@ -145,7 +145,7 @@ func (s *Session) OpenCluster(enableRPCCompression bool) error {
145
145
}
146
146
147
147
if s .config .ConnectRetryMax <= 0 {
148
- s .config .ConnectRetryMax = DefualtConnectRetryMax
148
+ s .config .ConnectRetryMax = DefaultConnectRetryMax
149
149
}
150
150
151
151
var protocolFactory thrift.TProtocolFactory
@@ -1059,7 +1059,7 @@ func (s *Session) initClusterConn(node endPoint) error {
1059
1059
}
1060
1060
1061
1061
if s .config .ConnectRetryMax < 1 {
1062
- s .config .ConnectRetryMax = DefualtConnectRetryMax
1062
+ s .config .ConnectRetryMax = DefaultConnectRetryMax
1063
1063
}
1064
1064
1065
1065
var protocolFactory thrift.TProtocolFactory
You can’t perform that action at this time.
0 commit comments