ORC-1591: Lower log level from INFO to DEBUG in `*ReaderImpl/WriterIm…

…pl/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]>
apache · Jan 16, 2024 · b126033 · b126033
1 parent 915c267
commit b126033
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 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
@@ -94,7 +94,7 @@ public PhysicalFsWriter(FileSystem fs,
     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 void appendRawStripe(ByteBuffer buffer,
     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
@@ -891,7 +891,7 @@ public RecordReader rows() throws IOException {
 
   @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
@@ -207,7 +207,7 @@ protected RecordReaderImpl(ReaderImpl fileReader,
     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
@@ -236,7 +236,7 @@ public WriterImpl(FileSystem fs,
 
     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);
   }