apache / apache/iotdb

[Bug] pipe data.delete error

未关闭
#17,816 2 条评论 0 个 reaction 已指派 0 人 在 GitHub 查看
主要语言
Java
星标
6.4k
派生
1.2k
平均合并
1 天 23 小时
30 天内合并 PR
115

描述

### Search before asking

- [x] I searched in the [issues](https://github.com/apache/iotdb/issues) and found nothing similar.

### Version

os: rh9.2 iotdb 2.0.5 use table

### Describe the bug and provide the minimal reproduce step

create pipe DA
with source (
'database-name'='nezha',
'mode.snapshot'='false',
'mode.streaming'='true',
'inclusion'='data.insert,data.delete',
)
with sink (
'sink'='iotdb-thrift-sink',
'node-urls' = '127.0.0.1:6669', -- 目标端 IoTDB 中 DataNode 节点的数据服务端口的 url
'username'='root',
'password'='xxxxxxxxxxx'
);

当我删除数据的时候pipe会直接报错并进入状态 stop

### What did you expect to see?

Data is synchronizing normally

### What did you see instead?

pipe error

### Anything else?

_No response_

### Are you willing to submit a PR?

- [ ] I'm willing to submit a PR!

贡献指南

打开贡献指南

调研方向

首先,在启用 data.insert 和 data.delete 流式处理的情况下,针对 IoTDB 2.0.5 重现 CREATE PIPE 语句,然后捕获删除数据时的 pipe 错误详情。在 pipe 和 thrift-sink 组件中追踪报告的失败;当删除操作能够正常同步且 pipe 保持运行时,即表示完成。

由索引模型根据 Issue 内容生成。

评估

技术栈
java
领域
databases, distributed-systems
Issue 类型
缺陷
难度
4/5
预计耗时
3-5 天
活跃度
冷清
描述清晰度
需要澄清
新手友好度
45/100

把新 issue 发到你的邮箱

精选适合新手参与的 GitHub issue 摘要。