amoro
amoro copied to clipboard
[Bug]: When querying a Mixed Iceberg table in Flink and Trino, multiple rows of data were returned for the same primary key.
What happened?
As described in the title.
Affects Versions
0.6.1
What engines are you seeing the problem on?
Flink, Trino
How to reproduce
- Create an Internal Mixed Iceberg format catalog
- Create a table with a primary key
- Insert CDC data into the table with Flink with stream mode
- Query the table in Flink and Trino with batch mode
Relevant log output
No response
Anything else
Query result is correct on Spark.
Are you willing to submit a PR?
- [ ] Yes I am willing to submit a PR!
Code of Conduct
- [X] I agree to follow this project's Code of Conduct