aboutsummaryrefslogtreecommitdiff
path: root/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java
diff options
context:
space:
mode:
authorVlad Rozov <vrozov@apache.org>2018-05-09 13:24:11 -0700
committerTimothy Farkas <timothyfarkas@apache.org>2018-06-13 17:11:29 -0700
commitac8e69847659582e36c89fd52bb0856ab3bfbd21 (patch)
tree917e881ff0bc693badbf152e629a75505ace8a90 /exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java
parent98dbc3a222990703aebe983883779763e0cdc1e9 (diff)
DRILL-6353: Upgrade Parquet MR dependencies
closes #1259
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java')
-rw-r--r--exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java4
1 files changed, 3 insertions, 1 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java
index ea34c7d8b..d1562c48c 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java
@@ -42,6 +42,7 @@ import org.apache.parquet.hadoop.metadata.ParquetMetadata;
import com.google.common.base.Preconditions;
import static org.apache.commons.lang3.builder.ToStringStyle.SHORT_PREFIX_STYLE;
+import static org.apache.parquet.format.converter.ParquetMetadataConverter.NO_FILTER;
public class FooterGatherer {
static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(FooterGatherer.class);
@@ -160,7 +161,8 @@ public class FooterGatherer {
footerBytes = ArrayUtils.subarray(footerBytes, start, start + size);
}
- ParquetMetadata metadata = ParquetFormatPlugin.parquetMetadataConverter.readParquetMetadata(new ByteArrayInputStream(footerBytes));
+ final ByteArrayInputStream from = new ByteArrayInputStream(footerBytes);
+ ParquetMetadata metadata = ParquetFormatPlugin.parquetMetadataConverter.readParquetMetadata(from, NO_FILTER);
Footer footer = new Footer(status.getPath(), metadata);
return footer;
}