You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/12/07 10:36:23 UTC
[iotdb-client-go] branch main updated: Remove debug codes from session.initClusterConn (#66)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iotdb-client-go.git
The following commit(s) were added to refs/heads/main by this push:
new 6550bc0 Remove debug codes from session.initClusterConn (#66)
6550bc0 is described below
commit 6550bc04f1ad4e82b4e44030ec818890417be464
Author: Mark Liu <ma...@gmail.com>
AuthorDate: Wed Dec 7 18:36:18 2022 +0800
Remove debug codes from session.initClusterConn (#66)
---
client/session.go | 4 ++--
client/utils_test.go | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/client/session.go b/client/session.go
index e45605a..6f39476 100644
--- a/client/session.go
+++ b/client/session.go
@@ -182,7 +182,7 @@ func (s *Session) OpenCluster(enableRPCCompression bool) error {
func (s *Session) Close() (r *rpc.TSStatus, err error) {
req := rpc.NewTSCloseSessionReq()
req.SessionId = s.sessionId
- r, err = s.client.CloseSession(context.Background(), req)
+ _, err = s.client.CloseSession(context.Background(), req)
if err != nil {
return nil, err
}
@@ -1064,7 +1064,7 @@ func (s *Session) initClusterConn(node endPoint) error {
s.client = rpc.NewTSIServiceClient(thrift.NewTStandardClient(iprot, oprot))
req := rpc.TSOpenSessionReq{ClientProtocol: rpc.TSProtocolVersion_IOTDB_SERVICE_PROTOCOL_V3, ZoneId: s.config.TimeZone, Username: &s.config.UserName,
Password: &s.config.Password}
- fmt.Println(req)
+
resp, err := s.client.OpenSession(context.Background(), &req)
if err != nil {
return err
diff --git a/client/utils_test.go b/client/utils_test.go
index 3554b8d..1714282 100644
--- a/client/utils_test.go
+++ b/client/utils_test.go
@@ -288,7 +288,7 @@ func Test_verifySuccesses(t *testing.T) {
name: "RedirectionRecommend",
args: args{
statuses: []*rpc.TSStatus{
- &rpc.TSStatus{
+ {
Code: RedirectionRecommend,
Message: &redirectionRecommend,
SubStatus: []*rpc.TSStatus{},