aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/test/java/org/apache
diff options
context:
space:
mode:
authorSalim Achouche <sachouche2@gmail.com>2019-03-12 18:06:43 -0700
committerTimothy Farkas <timothytiborfarkas@gmail.com>2019-03-13 12:17:01 -0700
commitb20a2e6b5ee82814011a031d8a8282b0fec3ffe1 (patch)
tree46c4565626f25ffb2b14dd8279e3d183810e8379 /exec/java-exec/src/test/java/org/apache
parente5e8419ab6fc1761cc7a6055b02f4300525e936e (diff)
DRILL-7100: Fixed IllegalArgumentException when reading Parquet data
Diffstat (limited to 'exec/java-exec/src/test/java/org/apache')
-rw-r--r--exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/columnreaders/TestBatchSizingMemoryUtil.java12
1 files changed, 6 insertions, 6 deletions
diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/columnreaders/TestBatchSizingMemoryUtil.java b/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/columnreaders/TestBatchSizingMemoryUtil.java
index 896675a3c..4cf150372 100644
--- a/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/columnreaders/TestBatchSizingMemoryUtil.java
+++ b/exec/java-exec/src/test/java/org/apache/drill/exec/store/parquet/columnreaders/TestBatchSizingMemoryUtil.java
@@ -93,9 +93,9 @@ public class TestBatchSizingMemoryUtil extends PhysicalOpUnitTestBase {
for (int columnIdx = 0; columnIdx < 3; columnIdx++) {
final ColumnMemoryUsageInfo columnInfo = columnMemoryInfo[columnIdx];
- final int remainingBitsCapacity = getRemainingBitsCapacity(columnInfo);
- final int remainingOffsetsCapacity = getRemainingOffsetsCapacity(columnInfo);
- final int remainingDataCapacity = getRemainingDataCapacity(columnInfo);
+ final long remainingBitsCapacity = getRemainingBitsCapacity(columnInfo);
+ final long remainingOffsetsCapacity = getRemainingOffsetsCapacity(columnInfo);
+ final long remainingDataCapacity = getRemainingDataCapacity(columnInfo);
// Test current VV is within quota (since we are not adding new entries)
Assert.assertTrue(BatchSizingMemoryUtil.canAddNewData(columnInfo, 0, 0, 0));
@@ -152,15 +152,15 @@ public class TestBatchSizingMemoryUtil extends PhysicalOpUnitTestBase {
return result;
}
- private static int getRemainingBitsCapacity(ColumnMemoryUsageInfo columnInfo) {
+ private static long getRemainingBitsCapacity(ColumnMemoryUsageInfo columnInfo) {
return columnInfo.vectorMemoryUsage.bitsBytesCapacity - columnInfo.vectorMemoryUsage.bitsBytesUsed;
}
- private static int getRemainingOffsetsCapacity(ColumnMemoryUsageInfo columnInfo) {
+ private static long getRemainingOffsetsCapacity(ColumnMemoryUsageInfo columnInfo) {
return columnInfo.vectorMemoryUsage.offsetsByteCapacity - columnInfo.vectorMemoryUsage.offsetsBytesUsed;
}
- private static int getRemainingDataCapacity(ColumnMemoryUsageInfo columnInfo) {
+ private static long getRemainingDataCapacity(ColumnMemoryUsageInfo columnInfo) {
return columnInfo.vectorMemoryUsage.dataByteCapacity - columnInfo.vectorMemoryUsage.dataBytesUsed;
}