forest455 opened a new issue, #8841:
URL: https://github.com/apache/hudi/issues/8841
After using HoodieMultiTableDeltaStreamer ingesting mysql Binlogs through
kafka-connector with Mysql Debezium, all change logs for each primary key
from source table are persisted into a hudi COW table. using presto as my
query engine I get all the change logs in a table ,however I want query the
latest snapshot of a table which means the result only consists one latest
updated record .
Can anyone help to instruct me to solve this problem. Thanks .
* Hudi version : 0.13.0
* Spark version : 3.3.1
* Hive version : 3.1.3
* Hadoop version : 3.1.1
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
