Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Bug]: When querying a Mixed Iceberg table in Flink and Trino, multiple rows of data were returned for the same primary key. #2713

Open
1 of 2 tasks
zhoujinsong opened this issue Apr 3, 2024 · 0 comments
Labels
type:bug Something isn't working

Comments

@zhoujinsong
Copy link
Contributor

zhoujinsong commented Apr 3, 2024

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

  • I agree to follow this project's Code of Conduct
@zhoujinsong zhoujinsong added the type:bug Something isn't working label Apr 3, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
type:bug Something isn't working
Projects
None yet
Development

No branches or pull requests

1 participant