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] Unable to async refresh dim table in full cache async lookup join when partition of dim table has been reloaded #4725

Open
2 tasks done
Dd969696 opened this issue Dec 17, 2024 · 0 comments
Labels
bug Something isn't working

Comments

@Dd969696
Copy link

Dd969696 commented Dec 17, 2024

Search before asking

  • I searched in the issues and found nothing similar.

Paimon version

0.9.0

Compute Engine

Flink

Minimal reproduce step

First async lookup join some paimon table in full cache mode with dynamic partition = max_pt(),
then create new partition in paimon table, finally the async task for refreshing local dim table will be rejected because executor thread pool has been terminated.
It will reopen lookupTable when partition has been changed (org.apache.paimon.flink.lookup.FileStoreLookupFunction#tryRefresh)
image
the executor thread pool for async refreshing local dim table task has been closed (org.apache.paimon.flink.lookup.FullCacheLookupTable#close)
image
but we won't build new thread pool, hence we will occur exception as follow:
image

What doesn't meet your expectations?

The executor thread pool for async refreshing local dim table task should be rebuilt and the refreshing task shouldn't be rejected.

Anything else?

No response

Are you willing to submit a PR?

  • I'm willing to submit a PR!
@Dd969696 Dd969696 added the bug Something isn't working label Dec 17, 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