File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -45,7 +45,7 @@ require (
4545 github.com/antchfx/xpath v1.3.6
4646 github.com/apache/arrow-go/v18 v18.5.2
4747 github.com/apache/inlong/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang v1.0.7
48- github.com/apache/iotdb-client-go v1.3.5
48+ github.com/apache/iotdb-client-go v1.3.7
4949 github.com/apache/thrift v0.22.0
5050 github.com/aristanetworks/goarista v0.0.0-20190325233358-a123909ec740
5151 github.com/armon/go-socks5 v0.0.0-20160902184237-e75332964ef5
Original file line number Diff line number Diff line change @@ -855,8 +855,8 @@ github.com/apache/arrow/go/v15 v15.0.2 h1:60IliRbiyTWCWjERBCkO1W4Qun9svcYoZrSLcy
855855github.com/apache/arrow/go/v15 v15.0.2 /go.mod h1:DGXsR3ajT524njufqf95822i+KTh+yea1jass9YXgjA =
856856github.com/apache/inlong/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang v1.0.7 h1:r1BYC/OGaKcav2llg5drf1ha1wL93LelKP2iPftI330 =
857857github.com/apache/inlong/inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang v1.0.7 /go.mod h1:FUTK5FZpCPgoZbuPeIEOd5v+CzJ6dXl6rEORxMras14 =
858- github.com/apache/iotdb-client-go v1.3.5 h1:UHWXC/0GWMw/u7/yUK9XA8vCsQj+6zHsHA4CKRZZCdE =
859- github.com/apache/iotdb-client-go v1.3.5 /go.mod h1:3D6QYkqRmASS/4HsjU+U/3fscyc5M9xKRfywZsKuoZY =
858+ github.com/apache/iotdb-client-go v1.3.7 h1:NHEW0yysGfxFQkkJpFHTlww1a/RHCINbOXBfv2/aIQ0 =
859+ github.com/apache/iotdb-client-go v1.3.7 /go.mod h1:3D6QYkqRmASS/4HsjU+U/3fscyc5M9xKRfywZsKuoZY =
860860github.com/apache/thrift v0.15.0 /go.mod h1:PHK3hniurgQaNMZYaCLEqXKsYK8upmhPbmdP2FXSqgU =
861861github.com/apache/thrift v0.16.0 /go.mod h1:PHK3hniurgQaNMZYaCLEqXKsYK8upmhPbmdP2FXSqgU =
862862github.com/apache/thrift v0.22.0 h1:r7mTJdj51TMDe6RtcmNdQxgn9XcyfGDOzegMDRg47uc =
Original file line number Diff line number Diff line change @@ -318,14 +318,13 @@ func (s *IoTDB) writeRecordsWithTags(rwt *recordsWithTags) error {
318318 return err
319319 }
320320 // write to IoTDB server
321- status , err := s .session .InsertRecords (rwt .DeviceIDList , rwt .MeasurementsList ,
322- rwt .DataTypesList , rwt .ValuesList , rwt .TimestampList )
323- if status != nil {
324- if verifyResult := client .VerifySuccess (status ); verifyResult != nil {
325- s .Log .Debug (verifyResult )
326- }
327- }
328- return err
321+ return s .session .InsertRecords (
322+ rwt .DeviceIDList ,
323+ rwt .MeasurementsList ,
324+ rwt .DataTypesList ,
325+ rwt .ValuesList ,
326+ rwt .TimestampList ,
327+ )
329328}
330329
331330func init () {
You can’t perform that action at this time.
0 commit comments