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] Partition expiration may conflict with in-flight compaction #3340

Open
2 tasks done
schnappi17 opened this issue May 16, 2024 · 0 comments
Open
2 tasks done

[Bug] Partition expiration may conflict with in-flight compaction #3340

schnappi17 opened this issue May 16, 2024 · 0 comments
Labels
bug Something isn't working

Comments

@schnappi17
Copy link
Contributor

schnappi17 commented May 16, 2024

Search before asking

  • I searched in the issues and found nothing similar.

Paimon version

release-0.7

Compute Engine

flink-1.17

Minimal reproduce step

  1. create partitioned table, set expired = 7d
  2. mock data to always generate partition 19700101
  3. 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 delete in 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 as delete and 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?

  • I'm willing to submit a PR!
@schnappi17 schnappi17 added the bug Something isn't working label May 16, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
bug Something isn't working
Projects
None yet
Development

No branches or pull requests

1 participant