diff options
author | Vlad Rozov <vrozov@apache.org> | 2018-05-09 13:24:11 -0700 |
---|---|---|
committer | Timothy Farkas <timothyfarkas@apache.org> | 2018-06-13 17:11:29 -0700 |
commit | ac8e69847659582e36c89fd52bb0856ab3bfbd21 (patch) | |
tree | 917e881ff0bc693badbf152e629a75505ace8a90 /exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/FooterGatherer.java | |
parent | 98dbc3a222990703aebe983883779763e0cdc1e9 (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.java | 4 |
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; } |