amoro icon indicating copy to clipboard operation
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.

Open zhoujinsong opened this issue 1 year ago • 0 comments

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

zhoujinsong avatar Apr 03 '24 08:04 zhoujinsong