apache / apache/iotdb

[Bug] pipe data.delete error

Open
#17,816 2 comments 0 reactions 0 assignees View on GitHub
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

Open the contributing 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

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.