apache / apache/iotdb

[Bug] pipe data.delete error

オープン
#17,816 コメント 2 件 リアクション 0 件 担当者 0 名 GitHub で見る
主要言語
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

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。