[Bug] flink CDCExample不能用
- 主要言語
- 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界面,这个实体是有数据的

### 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