Skip to content

Commit b29c006

Browse files
authored
[parquet] Add log to help debug in ParquetReaderFactory (#5180)
1 parent 75334ef commit b29c006

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

paimon-format/src/main/java/org/apache/paimon/format/parquet/ParquetReaderFactory.java

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -150,6 +150,15 @@ public FileRecordReader<InternalRow> createReader(FormatReaderFactory.Context co
150150
context.selection());
151151
MessageType fileSchema = reader.getFileMetaData().getSchema();
152152
MessageType requestedSchema = clipParquetSchema(fileSchema);
153+
154+
if (LOG.isDebugEnabled()) {
155+
LOG.debug(
156+
"Create reader of the parquet file {}, the fileSchema is {}, the requestedSchema is {}.",
157+
context.filePath(),
158+
fileSchema,
159+
requestedSchema);
160+
}
161+
153162
reader.setRequestedSchema(requestedSchema);
154163
WritableColumnVector[] writableVectors = createWritableVectors(requestedSchema);
155164

0 commit comments

Comments
 (0)