Fix Iceberg merge, update, delete, for tables with equality deletes - Githubissues

trinodb / trino

Official repository of Trino, the distributed SQL query engine for big data, formerly known as PrestoSQL (https://trino.io)

https://trino.io

Apache License 2.0

10.49k stars 3.02k forks source link

Fix Iceberg merge, update, delete, for tables with equality deletes #24062

Closed dain closed 2 days ago

dain commented 2 weeks ago

Description

Rewrite the creation of merge row id to avoid duplicate key exception.
Simplify by having data source produce row position for row id and then wrappering this block into a row id in IcebergPageSource
Remove unused update row id. This should have be removed during convertion to merge row ids.

Fixes #15952 Superseeds #16216

Release notes

(x) Release notes are required, with the following suggested text:

## Section
* Fix Iceberg merge, update, delete, for tables with equality deletes. ({issue}`15952`)