This is an automated email from the ASF dual-hosted git repository.
jiafengzheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-flink-connector.git
The following commit(s) were added to refs/heads/master by this push:
new a517114 fix lookup join when cache open (#116)
a517114 is described below
commit a517114d8fb585d6a7ad87e0181691c12281fc97
Author: wudi <[email protected]>
AuthorDate: Fri Mar 10 17:49:25 2023 +0800
fix lookup join when cache open (#116)
Co-authored-by: wudi <>
---
.../org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java
index b3c5f43..e6b2166 100644
---
a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java
+++
b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisRowDataAsyncLookupFunction.java
@@ -87,8 +87,8 @@ public class DorisRowDataAsyncLookupFunction extends
AsyncTableFunction<RowData>
List<RowData> cachedRows = cache.getIfPresent(keyRow);
if (cachedRows != null) {
future.complete(cachedRows);
+ return;
}
- return;
}
CompletableFuture<List<RowData>> resultFuture =
lookupReader.asyncGet(keyRow);
resultFuture.handleAsync(
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
