apache / apache/iotdb

[Bug] flink CDCExample不能用

オープン
#13,914 コメント 1 件 リアクション 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

iotdb 1.3.2

### Describe the bug and provide the minimal reproduce step

参考官方例子:
public static void main(String[] args) {
EnvironmentSettings settings = EnvironmentSettings.newInstance().inStreamingMode().build();
TableEnvironment tableEnv = TableEnvironment.create(settings);
// source
Schema sourceTableSchema =
Schema.newBuilder()
.column("Time_", DataTypes.BIGINT())
.column("root.zhang.table3.id", DataTypes.INT())
.column("root.zhang.table3.name", DataTypes.STRING())
.column("root.zhang.table3.address", DataTypes.STRING())
.build();

TableDescriptor tableDescriptor =
TableDescriptor.forConnector("IoTDB")
.schema(sourceTableSchema)
.option("mode", "CDC")
.option("cdc.task.name", "test2")
.option("cdc.pattern", "root.zhang.table3")
.option("cdc.port", "18089")
.build();
tableEnv.createTemporaryTable("source_table", tableDescriptor);

// output table
tableEnv.from("source_table").execute().print();

发现执行后,没有数据打印

在iot界面,这个实体是有数据的
![image](https://github.com/user-attachments/assets/67889731-ec10-4a0d-bc5d-c80d39195c5a)

### What did you expect to see?

期望官方例子 CDCExample,能够正确执行

### What did you see instead?

no

### Anything else?

_No response_

### Are you willing to submit a PR?

- [ ] I'm willing to submit a PR!

コントリビューションガイド

コントリビューションガイドを開く

調査の方向性

公式の CDCExample エントリーポイントから開始し、示されている CDC オプションとスキーマを使用して、提供された IoTDB 1.3.2 の再現手順を実行します。IoTDB インターフェース上ではエンティティにデータが存在するにもかかわらず、ソーステーブルを実行すると行が表示されない理由を確認します。root.zhang.table3 の CDC データが例で正しく表示されれば完了です。

索引モデルが issue の本文から書いたものです。

評価

技術スタック
java
領域
databases
issue の種類
バグ
難易度
4/5
見積もり時間
3〜5日
活発さ
停滞
明瞭さ
おおむね明確
初心者へのやさしさ
35/100

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

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