4paradigm / OpenMLDB

OpenMLDB is an open-source machine learning database that provides a feature platform computing consistent features for training and inference.
https://openmldb.ai
Apache License 2.0
1.59k stars 321 forks source link

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

Open blessnow opened 4 months ago

blessnow commented 4 months ago

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

blessnow commented 4 months ago

i deployed the environment according to :https://openmldb.ai/docs/zh/main/integration/online_datasources/kafka_connector_demo.html , it should be cluster mode