From a0397ae90c5ee7e6e48873735172a07715fec083 Mon Sep 17 00:00:00 2001 From: slfan1989 Date: Mon, 10 Oct 2022 21:38:01 +0800 Subject: [PATCH] HUDI-5002. Improve SparkHoodieHBaseIndex#generateStatement With Hbase Recommend Method. --- .../java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java index cf283ed0b1367..e6395b9c6d342 100644 --- a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java +++ b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java @@ -205,7 +205,7 @@ public void close() { } private Get generateStatement(String key) throws IOException { - return new Get(Bytes.toBytes(getHBaseKey(key))).setMaxVersions(1).addColumn(SYSTEM_COLUMN_FAMILY, COMMIT_TS_COLUMN) + return new Get(Bytes.toBytes(getHBaseKey(key))).readVersions(1).addColumn(SYSTEM_COLUMN_FAMILY, COMMIT_TS_COLUMN) .addColumn(SYSTEM_COLUMN_FAMILY, FILE_NAME_COLUMN).addColumn(SYSTEM_COLUMN_FAMILY, PARTITION_PATH_COLUMN); }