4paradigm / 4paradigm/OpenMLDB

online feature didn't change when using kafka to sink data to table

Aperta
#3,967 1 commento 0 reazioni 1 assegnatario Rivendicata da @aceforeverd Vedi su GitHub
bug
Lingua principale
C++
Stelle
1.7k
Fork
331
Merge medio
12g 12h
PR unite (30g)
1

Descrizione

**Bug Description**
openmldb single machine mode
feature: online feature deployment
datastream: using kafka to sink data to table
problems: when sink new data to the table from kafka, I expected feature could be changed, but it didn't happen, feature is old however.
using curl method to get feature: curl http://127.0.0.1:9080/dbs/kafka_test/deployments/demo_data_service -X POST -d'{"input": [[11, 2, 22, 1.2, 1.3, true,"c888", "2022-07-24",1751051906000]]}'

but use "load data into" cmd, feature can change as I expected.

**Expected Behavior**
when sink new data to the table from kafka, feature change too.

**Relation Case**

**Steps to Reproduce**

1.
2.
3.
4.

Guida per i contributori

Apri la guida per i contributori

Direzione di ricerca

The issue involves OpenMLDB's online feature deployment and Kafka data sinking. Start by examining the Kafka sink implementation and how table updates trigger feature recomputation. Look for integration points between the Kafka consumer and the feature serving layer. Reproduce the bug by setting up a single-machine OpenMLDB with Kafka, then compare the behavior of 'LOAD DATA' versus Kafka sink.

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

Valutazione

Stack tecnologico
kafka
Ambito
data-engineering, databases, machine-learning
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.