Websocket连接器报错

【TDengine 使用环境】
测试环境

【TDengine 版本】

服务端版本:3.3.7.0

客户端版本:taos-jdbcdriver:3.7.2

【操作系统以及版本】

centos7.9

【部署方式】容器/非容器部署

容器

【集群节点数】

1

【集群副本数】

1

【描述业务影响】

使用websocket进行数据插入

【问题复现路径/shan】做过哪些操作出现的问题

参照官网的例子使用websocket连接器进行数据插入

【遇到的问题:问题现象及影响】

客户端代码报错:

[ERROR] 2025-10-20 15:22:18.597 com.taos.example.highvolume.Test lambda$main$0 38 Thread-0 ERROR (0x231d): can’t create connection with server within: 60000 milliseconds
java.sql.SQLException: ERROR (0x231d): can’t create connection with server within: 60000 milliseconds
at com.taosdata.jdbc.TSDBError.createSQLException(TSDBError.java:94)
at com.taosdata.jdbc.ws.Transport.checkConnection(Transport.java:360)
at com.taosdata.jdbc.AbstractDriver.getWSConnection(AbstractDriver.java:99)
at com.taosdata.jdbc.ws.WebSocketDriver.connect(WebSocketDriver.java:37)
at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:683)
at java.sql/java.sql.DriverManager.getConnection(DriverManager.java:191)
at com.taos.example.highvolume.Util.getConnection(Util.java:43)
at com.taos.example.highvolume.Test.lambda$main$0(Test.java:24)
at java.base/java.lang.Thread.run(Thread.java:1583)

TDengine报错:

   10/20 15:10:48.148616 00000321 DB  ERROR QID:0x4000000000000075 latency:14.224404382s, sql:insert into km_9e54a43442f6_6043 using keeper_monitor tags (‘9e54a43442f6:6043’) values ( now,  0.016667, 0.107293, 0), err:Post “http://127.0.0.1:6041/rest/sql/log?req_id=8377011997561061479”: read tcp 127.0.0.1:43500->127.0.0.1:6041: read: connection reset by peer10/20 15:10:48.148696 00000321 MON ERROR execute sql:insert into km_9e54a43442f6_6043 using keeper_monitor tags (‘9e54a43442f6:6043’) values ( now,  0.016667, 0.107293, 0), error:Post “http://127.0.0.1:6041/rest/sql/log?req_id=8377011997561061479”: read tcp 127.0.0.1:43500->127.0.0.1:6041: read: connection reset by peer10/20 15:10:48.148854 00000321 DB  ERROR QID:0x10000000001bc00 latency:4.232377899s, sql:insert into log.taosd_cluster_basic_7973313584772425462 using taosd_cluster_basic tags (‘7973313584772425462’) values (1760944243915, ‘localhost:6030’, 1, ‘3.3.7.0’) , err:Post “http://127.0.0.1:6041/rest/sql/log?req_id=8377011997601955944”: read tcp 127.0.0.1:43292->127.0.0.1:6041: read: connection reset by peer10/20 15:10:48.148953 00000321 GEN ERROR QID:0x10000000001bc00 insert taosd_cluster_basic error, msg:Post “http://127.0.0.1:6041/rest/sql/log?req_id=8377011997601955944”: read tcp 127.0.0.1:43292->127.0.0.1:6041: read: connection reset by peer/usr/bin/entrypoint.sh: line 116:   278 Segmentation fault      (core dumped) taosadapter10/20 15:10:48.149199 00000321 WEB ERROR
2025/10/20 15:10:48 [Recovery] 2025/10/20 - 15:10:48 panic recovered:runtime error: invalid memory address or nil pointer dereference/root/.gvm/gos/go1.24.2/src/runtime/panic.go:262 (0x47daf8)/root/.gvm/gos/go1.24.2/src/runtime/signal_unix.go:925 (0x47dac8)/data/release/main/TDinternal/community/tools/keeper/api/gen_metric.go:303 (0xb8976e)/data/release/main/TDinternal/community/tools/keeper/api/gen_metric.go:262 (0xb88c1c)/data/release/main/TDinternal/community/tools/keeper/api/gen_metric.go:217 (0xb88244)/root/.gvm/pkgsets/go1.24.2/global/pkg/mod/github.com/gin-gonic/gin@v1.9.1/context.go:174 (0x95566e)/root/.gvm/pkgsets/go1.24.2/global/pkg/mod/github.com/gin-gonic/gin@v1.9.1/recovery.go:102 (0x95565b)/data/release/main/TDinternal/community/tools/keeper/infrastructure/log/web.go:53 (0xa9817b)/root/.gvm/pkgsets/go1.24.2/global/pkg/mod/github.com/gin-gonic/gin@v1.9.1/context.go:174 (0xa97b86)/data/release/main/TDinternal/community/tools/keeper/infrastructure/log/web.go:24 (0xa97b6d)/root/.gvm/pkgsets/go1.24.2/global/pkg/mod/github.com/gin-gonic/gin@v1.9.1/context.go:174 (0x9544ad)/root/.gvm/pkgsets/go1.24.2/global/pkg/mod/github.com/gin-gonic/gin@v1.9.1/gin.go:620 (0x954144)/root/.gvm/pkgsets/go1.24.2/global/pkg/mod/github.com/gin-gonic/gin@v1.9.1/gin.go:576 (0x953c89)/root/.gvm/gos/go1.24.2/src/net/http/server.go:3301 (0x71c44d)/root/.gvm/gos/go1.24.2/src/net/http/server.go:2102 (0x6f9e84)/root/.gvm/gos/go1.24.2/src/runtime/asm_amd64.s:1700 (0x483880)

【资源配置】

测试客户端和服务器均为8c16g

【报错完整截图】

之前也问过这个问题,但是一直都没有收到有效的回复。目前从我自己的测试情况看,只要使用websocket连接器进行高性能插入,tdengine就会崩溃。

我使用的是官方文档中的websocket高性能插入的例子代码,还特地调低了相关参数,只使用了一个数据库连接。

batchSizeByRow = 100;
cacheSizeByRow = 1000;
writeThreadCount = 3;

好的我们看一下

麻烦微信添加一下 a15652223354

经过沟通,是参数绑定语句使用了函数 now。目前参数绑定不支持函数。修改后正常。我们会优化 core 问题。