This is an automated email from the ASF dual-hosted git repository.
dongjoon pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/orc.git
The following commit(s) were added to refs/heads/main by this push:
new b1260337e ORC-1591: Lower log level from INFO to DEBUG in
`*ReaderImpl/WriterImpl/PhysicalFsWriter`
b1260337e is described below
commit b1260337e0d9020223cdb72b488930d2d6c6f87d
Author: Dongjoon Hyun <[email protected]>
AuthorDate: Tue Jan 16 14:13:07 2024 -0800
ORC-1591: Lower log level from INFO to DEBUG in
`*ReaderImpl/WriterImpl/PhysicalFsWriter`
### What changes were proposed in this pull request?
This PR aims to lower several log message's level from INFO to DEBUG.
### Why are the changes needed?
To reduce verbose INFO level messages.
### How was this patch tested?
Manual test because these are log-level changes.
### Was this patch authored or co-authored using generative AI tooling?
No.
Closes #1754 from dongjoon-hyun/ORC-1591.
Authored-by: Dongjoon Hyun <[email protected]>
Signed-off-by: Dongjoon Hyun <[email protected]>
---
java/core/src/java/org/apache/orc/impl/PhysicalFsWriter.java | 4 ++--
java/core/src/java/org/apache/orc/impl/ReaderImpl.java | 2 +-
java/core/src/java/org/apache/orc/impl/RecordReaderImpl.java | 2 +-
java/core/src/java/org/apache/orc/impl/WriterImpl.java | 2 +-
4 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/java/core/src/java/org/apache/orc/impl/PhysicalFsWriter.java
b/java/core/src/java/org/apache/orc/impl/PhysicalFsWriter.java
index 38a8edd25..deaf63446 100644
--- a/java/core/src/java/org/apache/orc/impl/PhysicalFsWriter.java
+++ b/java/core/src/java/org/apache/orc/impl/PhysicalFsWriter.java
@@ -94,7 +94,7 @@ public class PhysicalFsWriter implements PhysicalWriter {
this(fs.create(path, opts.getOverwrite(), HDFS_BUFFER_SIZE,
fs.getDefaultReplication(path), opts.getBlockSize()), opts,
encryption);
this.path = path;
- LOG.info("ORC writer created for path: {} with stripeSize: {} blockSize:
{}" +
+ LOG.debug("ORC writer created for path: {} with stripeSize: {} blockSize:
{}" +
" compression: {}", path, opts.getStripeSize(), blockSize,
compress);
}
@@ -509,7 +509,7 @@ public class PhysicalFsWriter implements PhysicalWriter {
if (length < blockSize && length > availBlockSpace &&
addBlockPadding) {
byte[] pad = new byte[(int) Math.min(HDFS_BUFFER_SIZE, availBlockSpace)];
- LOG.info("Padding ORC by {} bytes while merging", availBlockSpace);
+ LOG.debug("Padding ORC by {} bytes while merging", availBlockSpace);
start += availBlockSpace;
while (availBlockSpace > 0) {
int writeLen = (int) Math.min(availBlockSpace, pad.length);
diff --git a/java/core/src/java/org/apache/orc/impl/ReaderImpl.java
b/java/core/src/java/org/apache/orc/impl/ReaderImpl.java
index b80094b58..3afbff5fc 100644
--- a/java/core/src/java/org/apache/orc/impl/ReaderImpl.java
+++ b/java/core/src/java/org/apache/orc/impl/ReaderImpl.java
@@ -891,7 +891,7 @@ public class ReaderImpl implements Reader {
@Override
public RecordReader rows(Options options) throws IOException {
- LOG.info("Reading ORC rows from " + path + " with " + options);
+ LOG.debug("Reading ORC rows from " + path + " with " + options);
return new RecordReaderImpl(this, options);
}
diff --git a/java/core/src/java/org/apache/orc/impl/RecordReaderImpl.java
b/java/core/src/java/org/apache/orc/impl/RecordReaderImpl.java
index 791957345..c2dbfd469 100644
--- a/java/core/src/java/org/apache/orc/impl/RecordReaderImpl.java
+++ b/java/core/src/java/org/apache/orc/impl/RecordReaderImpl.java
@@ -207,7 +207,7 @@ public class RecordReaderImpl implements RecordReader {
OrcFile.WriterVersion writerVersion = fileReader.getWriterVersion();
SchemaEvolution evolution;
if (options.getSchema() == null) {
- LOG.info("Reader schema not provided -- using file schema " +
+ LOG.debug("Reader schema not provided -- using file schema " +
fileReader.getSchema());
evolution = new SchemaEvolution(fileReader.getSchema(), null, options);
} else {
diff --git a/java/core/src/java/org/apache/orc/impl/WriterImpl.java
b/java/core/src/java/org/apache/orc/impl/WriterImpl.java
index 9100aa374..776baa28a 100644
--- a/java/core/src/java/org/apache/orc/impl/WriterImpl.java
+++ b/java/core/src/java/org/apache/orc/impl/WriterImpl.java
@@ -236,7 +236,7 @@ public class WriterImpl implements WriterInternal,
MemoryManager.Callback {
treeWriter = TreeWriter.Factory.create(schema, null, new StreamFactory());
- LOG.info("ORC writer created for path: {} with stripeSize: {} options: {}",
+ LOG.debug("ORC writer created for path: {} with stripeSize: {} options:
{}",
path, stripeSize, unencryptedOptions);
}