paimon
paimon copied to clipboard
[Bug] Partition expiration may conflict with in-flight compaction
Search before asking
- [X] I searched in the issues and found nothing similar.
Paimon version
release-0.7
Compute Engine
flink-1.17
Minimal reproduce step
- create partitioned table, set expired = 7d
- mock data to always generate partition 19700101
- sometimes it'll failover because compact deletion will conflict with the partition expiration.
Let's say there is fileA which need to be marked as
deletein a partition expiration task, and writer suppose the file still exists and pick it in a compaction task. Then compaction task will be finished with committing it asdeleteand will result in deleting a file which is not recorded by the base manifest.
What doesn't meet your expectations?
This caused a flink job failover
Anything else?
No response
Are you willing to submit a PR?
- [X] I'm willing to submit a PR!