[Bug] pipe data.delete error
- Dominant language
- Java
- Stars
- 6.4k
- Forks
- 1.2k
- Avg merge
- 1d 23h
- Merged PRs (30d)
- 115
Description
### 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!
Contributor guide
Research direction
Start by reproducing the CREATE PIPE statement against IoTDB 2.0.5 with streaming data.insert and data.delete enabled, then capture the pipe error details when deleting data. Trace the reported failure in the pipe and thrift-sink components; done means deletes synchronize normally and the pipe remains running.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- databases, distributed-systems
- Issue type
- Bug
- Difficulty
- 4/5
- Estimated time
- 3-5 days
- Activity status
- Quiet
- Clarity
- Needs clarification
- Newbie friendliness
- 45/100