[Bug] pipe data.delete error
- 主要言語
- Java
- スター
- 6.4k
- フォーク
- 1.2k
- 平均マージ
- 1日 23時間
- マージ済み PR(30日)
- 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