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() {