From 0d4176d5c476e3ac77d9be6416c601aab9bf8dc7 Mon Sep 17 00:00:00 2001 From: huiruan Date: Sat, 25 Apr 2026 19:27:45 +0800 Subject: [PATCH] HBASE-30116 Fix TableSnapshotInputFormat#getLen() returning zero for valid snapshot splits --- .../hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.java b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.java index 501209f1c902..b4cf394ed8b4 100644 --- a/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.java +++ b/hbase-mapreduce/src/main/java/org/apache/hadoop/hbase/mapreduce/TableSnapshotInputFormatImpl.java @@ -182,7 +182,10 @@ public String getRestoreDir() { public long getLength() { // TODO: We can obtain the file sizes of the snapshot here. - return 0; + // returns a valid positive length instead of 0 to avoid + // Spark's empty-partition filtering which was introduced via SPARK-22233 + // and enabled by default in SPARK-34809 + return 1L; } public String[] getLocations() {