This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 881b2bf046e [FLINK-28861][table] Fix bug in UID format for future
migrations and make it configurable
add cd173e71162 [FLINK-28899][table-planner] Fix LOOKUP hint with retry
option on async lookup mode
No new revisions were added by this update.
Summary of changes:
.../nodes/exec/common/CommonExecLookupJoin.java | 10 +-
.../table/planner/plan/utils/LookupJoinUtil.java | 42 +++++-
.../runtime/stream/sql/AsyncLookupJoinITCase.scala | 11 +-
.../operators/join/lookup/ResultRetryStrategy.java | 4 +-
.../RetryableAsyncLookupFunctionDelegator.java | 102 +++++++++++++
.../RetryableAsyncLookupFunctionDelegatorTest.java | 168 +++++++++++++++++++++
6 files changed, 318 insertions(+), 19 deletions(-)
create mode 100644
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/lookup/RetryableAsyncLookupFunctionDelegator.java
create mode 100644
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/join/RetryableAsyncLookupFunctionDelegatorTest.java
