4paradigm / 4paradigm/OpenMLDB

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

Aberta
#3,967 1 comentário 0 reações 1 responsável Reivindicada por @aceforeverd Ver no GitHub
bug
Linguagem predominante
C++
Estrelas
1.7k
Forks
331
Merge médio
12d 12h
PRs com merge (30d)
1

Descrição

**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.

Guia de contribuição

Abrir o guia de contribuição

Direção de pesquisa

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.

Escrita pelo modelo de indexação a partir do texto da issue.

Avaliação

Stack de tecnologia
kafka
Domínio
data-engineering, databases, machine-learning
Tipo de issue
Bug
Dificuldade
4/5
Tempo estimado
3-5 dias
Status de atividade
Estagnada
Clareza
Razoavelmente clara
Facilidade para iniciantes
35/100

Receba novas issues na sua caixa de entrada

Um resumo curto de issues do GitHub para quem está começando.