Skip to content

Commit

Permalink
print file path in the warning
Browse files Browse the repository at this point in the history
  • Loading branch information
wgtmac committed Jan 11, 2023
1 parent a496c31 commit e14d18f
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -929,7 +929,7 @@ public PageReadStore readNextRowGroup() throws IOException {
try {
rowGroup = internalReadRowGroup(currentBlock);
} catch (ParquetEmptyBlockException e) {
LOG.warn("Read empty block at index {}", currentBlock);
LOG.warn("Read empty block at index {} from {}", currentBlock, getFile());
advanceToNextBlock();
return readNextRowGroup();
}
Expand Down Expand Up @@ -1044,7 +1044,7 @@ public PageReadStore readNextFilteredRowGroup() throws IOException {
}
BlockMetaData block = blocks.get(currentBlock);
if (block.getRowCount() == 0L) {
LOG.warn("Read empty block at index {}", currentBlock);
LOG.warn("Read empty block at index {} from {}", currentBlock, getFile());
// Skip the empty block
advanceToNextBlock();
return readNextFilteredRowGroup();
Expand Down

0 comments on commit e14d18f

Please sign in to comment.