paimon
paimon copied to clipboard
[flink][lookup] Support async refresh of lookup table
Purpose
Linked issue: close #3295
This PR aims to add async refresh of lookup table to avoid lag in job when the lookup operator is blocked by refresh data from table store
Tests
- Updated existing test for refresh async in FileStoreLookupFunctionTest
- Added LookupTableTest#testPKLookupTableRefreshAsync for refresh async
API and Format
no
Documentation
no