[doris-flink-connector] branch master updated: fix lookup join when cache open (#116)

[jiafengzheng]

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 <676366...@qq.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org