-
Notifications
You must be signed in to change notification settings - Fork 998
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
[core] Make the refreshAsync options take affect to PrimaryKeyPartialLookupTable #4208
base: master
Are you sure you want to change the base?
Conversation
1f69190
to
a623f81
Compare
@FangYongs @JingsongLi Would you kindly review this when you have time? |
...k/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FullCacheLookupTable.java
Show resolved
Hide resolved
...k/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FullCacheLookupTable.java
Outdated
Show resolved
Hide resolved
...aimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/AsyncRefreshLookupTable.java
Outdated
Show resolved
Hide resolved
CC @liming30 too |
The purpose of introducing asynchronous refresh in #3297 is to solve the problem that local data refresh will block |
@liming30 Thx for reply. I see your point. Maybe I should split this task into two tasks: 1, Make the refreshAsync options also work for PrimaryKeyPartialLookupTable; 2, Improve the refresh behavior for LocalQueryExecutor, create local LookupFile during refresh according to the before and after DataFileMetas in a DataSplit. WDYT? |
Purpose
Linked issue: close #3386
Support async refresh for PrimaryKeyPartialLookupTable
Tests
API and Format
Documentation