From 0ac7bda1f102a591454583241000b9cbb9a8de48 Mon Sep 17 00:00:00 2001
From: xiekunyuan <xiekunyuan@meizu.com>
Date: Fri, 15 Sep 2023 19:08:12 +0800
Subject: [PATCH] fix: convertToReusedRow() is now returned by default, and the
 result returned is a reused object. If lookup.cache is enabled, the result
 encapsulated in the reused object will be cached externally, resulting in all
 cached values being the same object

---
 .../connector/hbase/source/HBaseRowDataLookupFunction.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataLookupFunction.java b/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataLookupFunction.java
index 0e1ba542..59edf308 100644
--- a/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataLookupFunction.java
+++ b/flink-connector-hbase-base/src/main/java/org/apache/flink/connector/hbase/source/HBaseRowDataLookupFunction.java
@@ -97,7 +97,7 @@ public Collection<RowData> lookup(RowData keyRow) throws IOException {
                 if (get != null) {
                     Result result = table.get(get);
                     if (!result.isEmpty()) {
-                        return Collections.singletonList(serde.convertToReusedRow(result));
+                        return Collections.singletonList(serde.convertToNewRow(result));
                     }
                 }
                 break;