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