apache / apache/iotdb

[Bug] flink CDCExample不能用

Aperta
#13,914 1 commento 0 reazioni 0 assegnatari Vedi su GitHub
Lingua principale
Java
Stelle
6.4k
Fork
1.2k
Merge medio
1g 23h
PR unite (30g)
115

Descrizione

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

Guida per i contributori

Apri la guida per i contributori

Direzione di ricerca

Inizia dal punto di ingresso ufficiale di CDCExample ed esegui la riproduzione fornita per IoTDB 1.3.2 con le opzioni CDC e lo schema mostrati. Verifica perché l’esecuzione della tabella di origine non stampa alcuna riga, anche se l’entità contiene dati nell’interfaccia di IoTDB. Il lavoro è completato quando l’esempio stampa correttamente i dati CDC per root.zhang.table3.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Valutazione

Stack tecnologico
java
Ambito
databases
Tipo di issue
Bug
Difficoltà
4/5
Tempo stimato
3-5 giorni
Stato di attività
Ferma
Chiarezza
Abbastanza chiara
Idoneità per principianti
35/100

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.