apache / apache/iotdb

[Bug] flink CDCExample不能用

Offen
#13,914 1 Kommentar 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
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

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!

Beitragsleitfaden

Beitragsleitfaden öffnen

Rechercherichtung

Beginne mit dem offiziellen CDCExample-Einstiegspunkt und führe die bereitgestellte IoTDB-1.3.2-Reproduktion mit den gezeigten CDC-Optionen und dem gezeigten Schema aus. Prüfe, warum die Ausführung der Quelltabelle keine Zeilen ausgibt, obwohl die Entität in der IoTDB-Oberfläche Daten enthält. Als erledigt gilt die Aufgabe, wenn das Beispiel die CDC-Daten für root.zhang.table3 korrekt ausgibt.

Vom Indexierungsmodell aus dem Issue-Text verfasst.

Bewertung

Tech-Stack
java
Bereich
databases
Issue-Typ
Bug
Schwierigkeit
4/5
Geschätzter Aufwand
3-5 Tage
Aktivitätsstatus
Veraltet
Klarheit
Größtenteils klar
Anfängerfreundlichkeit
35/100

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.