[Bug] pipe data.delete error
- Vorherrschende Sprache
- Java
- Sterne
- 6.4k
- Forks
- 1.2k
- Ø Merge
- 1 T. 23 Std.
- Gemergte PRs (30 T.)
- 115
Beschreibung
### 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!
Beitragsleitfaden
Rechercherichtung
Beginne damit, die CREATE PIPE-Anweisung gegen IoTDB 2.0.5 mit aktiviertem Streaming für data.insert und data.delete zu reproduzieren, und erfasse anschließend die Pipe-Fehlerdetails beim Löschen von Daten. Verfolge den gemeldeten Fehler in den Komponenten pipe und thrift-sink zurück; abgeschlossen ist die Aufgabe, wenn Löschvorgänge normal synchronisiert werden und die Pipe weiter ausgeführt wird.
Vom Indexierungsmodell aus dem Issue-Text verfasst.
Bewertung
- Tech-Stack
- java
- Bereich
- databases, distributed-systems
- Issue-Typ
- Bug
- Schwierigkeit
- 4/5
- Geschätzter Aufwand
- 3-5 Tage
- Aktivitätsstatus
- Ruhig
- Klarheit
- Muss geklärt werden
- Anfängerfreundlichkeit
- 45/100