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 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;