This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 0d863f84a96 [MINOR] Updating logging usage and level for noisier logs 
(#11345)
0d863f84a96 is described below

commit 0d863f84a9653ba965b2e298beb64ff29980a87e
Author: Tim Brown <[email protected]>
AuthorDate: Tue May 28 01:53:11 2024 -0700

    [MINOR] Updating logging usage and level for noisier logs (#11345)
---
 .../apache/hudi/common/table/log/HoodieLogFormatReader.java  |  2 +-
 .../java/org/apache/hudi/metadata/BaseTableMetadata.java     | 12 ++++++------
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java
 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java
index b893a4eac41..07cbe9ff20c 100644
--- 
a/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java
+++ 
b/hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java
@@ -91,7 +91,7 @@ public class HoodieLogFormatReader implements 
HoodieLogFormat.Reader {
       } catch (IOException io) {
         throw new HoodieIOException("unable to initialize read with log file 
", io);
       }
-      LOG.info("Moving to the next reader for logfile {}", 
currentReader.getLogFile());
+      LOG.debug("Moving to the next reader for logfile {}", 
currentReader.getLogFile());
       return hasNext();
     }
     return false;
diff --git 
a/hudi-common/src/main/java/org/apache/hudi/metadata/BaseTableMetadata.java 
b/hudi-common/src/main/java/org/apache/hudi/metadata/BaseTableMetadata.java
index 5c57e1b4d58..53066a7d320 100644
--- a/hudi-common/src/main/java/org/apache/hudi/metadata/BaseTableMetadata.java
+++ b/hudi-common/src/main/java/org/apache/hudi/metadata/BaseTableMetadata.java
@@ -175,7 +175,7 @@ public abstract class BaseTableMetadata extends 
AbstractHoodieTableMetadata {
     final Pair<String, String> partitionFileName = Pair.of(partitionName, 
fileName);
     Map<Pair<String, String>, BloomFilter> bloomFilters = 
getBloomFilters(Collections.singletonList(partitionFileName));
     if (bloomFilters.isEmpty()) {
-      LOG.error("Meta index: missing bloom filter for partition: " + 
partitionName + ", file: " + fileName);
+      LOG.error("Meta index: missing bloom filter for partition: {}, file: 
{}", partitionName, fileName);
       return Option.empty();
     }
 
@@ -228,7 +228,7 @@ public abstract class BaseTableMetadata extends 
AbstractHoodieTableMetadata {
           partitionFileToBloomFilterMap.put(fileToKeyMap.get(entry.getKey()), 
bloomFilter);
         }
       } else {
-        LOG.error("Meta index bloom filter missing for: " + 
fileToKeyMap.get(entry.getKey()));
+        LOG.error("Meta index bloom filter missing for: {}", 
fileToKeyMap.get(entry.getKey()));
       }
     }
     return partitionFileToBloomFilterMap;
@@ -272,7 +272,7 @@ public abstract class BaseTableMetadata extends 
AbstractHoodieTableMetadata {
           fileToColumnStatMap.put(partitionFileNamePair, 
columnStatMetadata.get());
         }
       } else {
-        LOG.error("Meta index column stats missing for: " + entry.getKey());
+        LOG.error("Meta index column stats missing for: {}", entry.getKey());
       }
     }
     return fileToColumnStatMap;
@@ -335,7 +335,7 @@ public abstract class BaseTableMetadata extends 
AbstractHoodieTableMetadata {
     })
         .orElse(Collections.emptyList());
 
-    LOG.info("Listed partitions from metadata: #partitions=" + 
partitions.size());
+    LOG.info("Listed partitions from metadata: #partitions={}", 
partitions.size());
     return partitions;
   }
 
@@ -365,7 +365,7 @@ public abstract class BaseTableMetadata extends 
AbstractHoodieTableMetadata {
         })
         .orElseGet(Collections::emptyList);
 
-    LOG.info("Listed file in partition from metadata: partition=" + 
relativePartitionPath + ", #files=" + pathInfoList.size());
+    LOG.debug("Listed file in partition from metadata: partition={}, 
#files={}", relativePartitionPath, pathInfoList.size());
     return pathInfoList;
   }
 
@@ -402,7 +402,7 @@ public abstract class BaseTableMetadata extends 
AbstractHoodieTableMetadata {
             })
         .collect(Collectors.toMap(Pair::getKey, Pair::getValue));
 
-    LOG.info("Listed files in " + partitionPaths.size() + " partitions from 
metadata");
+    LOG.info("Listed files in {} partitions from metadata", 
partitionPaths.size());
 
     return partitionPathToFilesMap;
   }

Reply via email to