Fix the size of all-null blocks returned from Float reader
@@ -312,7 +312,7 @@ public class FloatSelectiveStreamReader
checkState(!valuesInUse, "BlockLease hasn't been closed yet");
if (allNulls) {
- return new RunLengthEncodedBlock(NULL_BLOCK, outputPositionCount);
+ return new RunLengthEncodedBlock(NULL_BLOCK, positionCount);
}
boolean includeNulls = nullsAllowed && presentStream != null;
@@ -363,7 +363,7 @@ public class FloatSelectiveStreamReader
checkState(!valuesInUse, "BlockLease hasn't been closed yet");
if (allNulls) {
- return newLease(new RunLengthEncodedBlock(NULL_BLOCK, outputPositionCount));
+ return newLease(new RunLengthEncodedBlock(NULL_BLOCK, positionCount));
}
boolean includeNulls = nullsAllowed && presentStream != null;
