Skip to content

Commit

Permalink
Remove dead code
Browse files Browse the repository at this point in the history
  • Loading branch information
dain committed Mar 13, 2019
1 parent 6bef910 commit b47e1c0
Showing 1 changed file with 1 addition and 7 deletions.
8 changes: 1 addition & 7 deletions presto-orc/src/main/java/io/prestosql/orc/StripeReader.java
Original file line number Diff line number Diff line change
Expand Up @@ -118,7 +118,6 @@ public Stripe readStripe(StripeInformation stripe, AggregatedMemoryContext syste

// get streams for selected columns
Map<StreamId, Stream> streams = new HashMap<>();
boolean hasRowGroupDictionary = false;
for (Stream stream : stripeFooter.getStreams()) {
if (includedOrcColumns.contains(stream.getColumn())) {
streams.put(new StreamId(stream), stream);
Expand Down Expand Up @@ -173,12 +172,7 @@ public Stripe readStripe(StripeInformation stripe, AggregatedMemoryContext syste
return new Stripe(stripe.getNumberOfRows(), timeZone, columnEncodings, rowGroups, dictionaryStreamSources);
}
catch (InvalidCheckpointException e) {
// The ORC file contains a corrupt checkpoint stream
// If the file does not have a row group dictionary, treat the stripe as a single row group. Otherwise,
// we must fail because the length of the row group dictionary is contained in the checkpoint stream.
if (hasRowGroupDictionary) {
throw new OrcCorruptionException(e, orcDataSource.getId(), "Checkpoints are corrupt");
}
// The ORC file contains a corrupt checkpoint stream treat the stripe as a single row group.
invalidCheckPoint = true;
}
}
Expand Down

0 comments on commit b47e1c0

Please sign in to comment.