CnosDB 2.3.3执行\w oceanic_station.txt写入失败，请求技术排查

环境信息 #

• cnosdb-cli 已添加至系统路径
• 版本：cnosdb 2.3.3，修订版 d86358a6fc813f4b83b36f0005448e7140a2d4e0

CLI操作日志 #

public ❯ \d
查询耗时0.003秒。
public ❯ \w oceanic_station.txt
查询耗时0.419秒。
public ❯ \d
+------------+
| table_name |
+------------+
| air        |
| wind       |
+------------+
查询耗时0.014秒。
public ❯ \d
查询耗时0.043秒。
public ❯ \w oceanic_station.txt
查询耗时0.372秒。
public ❯ \d
+------------+
| table_name |
+------------+
| air        |
+------------+
查询耗时0.010秒。

错误日志 #

2023-10-24T20:04:07.147874000+08:00 DEBUG coordinator::writer: 向本地节点1001(3)写入数据失败，错误信息：Meta { source: MetaClientErr { msg: "NetworkError: reqwest::error::Error: error sending request for url (http://127.0.0.1:8901/read): connection closed before message completed source: connection closed before message completed" } }
2023-10-24T20:04:07.148068000+08:00 DEBUG coordinator::writer: vnode并行写入点完成，开始时间：Instant { tv_sec: 891340, tv_nsec: 230825166 }，耗时：48毫秒，结果：Err(Meta { source: MetaClientErr { msg: "NetworkError: reqwest::error::Error: error sending request for url (http://127.0.0.1:8901/read): connection closed before message completed source: connection closed before message completed" } })
2023-10-24T20:04:07.834871000+08:00 DEBUG meta::store::state_machine: 元数据处理写入命令ReportNodeMetrics("cluster_xxx", NodeMetrics { id: 1001, disk_free: 91437920256, time: 1698149047, status: Healthy })
2023-10-24T20:04:07.835068000+08:00  INFO meta::store::state_machine: 元数据写入：/data_version :13
2023-10-24T20:04:07.835092000+08:00  INFO meta::store::state_machine: 元数据写入：/cluster_xxx/data_nodes_metrics/1001 :{"id":1001,"disk_free":91437920256,"time":1698149047,"status":"Healthy"}
2023-10-24T20:04:08.535215000+08:00 DEBUG cnosdb::http::http_service: 接收HTTP SQL请求，请求头：Header { accept: Some("application/table"), authorization: "Basic cm9vdDo=", private_key: None }，参数：SqlParam { tenant: Some("cnosdb"), db: Some("public"), chunked: None, target_partitions: None, stream_trigger_interval: None }
2023-10-24T20:04:08.535358000+08:00 DEBUG cnosdb::http::http_service: 准备执行："SHOW TABLES"

问题核心点 #

1. 执行\w oceanic_station.txt命令后，原有表wind丢失，写入操作未完成且触发数据异常
2. 根因是元数据客户端与本地节点1001的通信中断：连接在请求消息完成前被关闭
3. 节点状态报告为健康，但数据写入链路的网络通信存在异常

内容的提问来源于stack exchange，提问作者cosmic