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);
   }
 

Reply via email to