This is an automated email from the ASF dual-hosted git repository.
yihua pushed a commit to branch branch-0.x
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/branch-0.x by this push:
new 4684082406c [MINOR] Avoid logging full commit metadata at info level
(#11382)
4684082406c is described below
commit 4684082406c4d23c97b25e96297b7c05fd653208
Author: Tim Brown <[email protected]>
AuthorDate: Mon Jun 3 11:01:42 2024 -0500
[MINOR] Avoid logging full commit metadata at info level (#11382)
---
.../org/apache/hudi/client/BaseHoodieTableServiceClient.java | 9 ++++++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieTableServiceClient.java
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieTableServiceClient.java
index 7dcff3bd6f2..ff0f635b06e 100644
---
a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieTableServiceClient.java
+++
b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieTableServiceClient.java
@@ -327,7 +327,8 @@ public abstract class BaseHoodieTableServiceClient<I, T, O>
extends BaseHoodieCl
finalizeWrite(table, compactionCommitTime, writeStats);
// commit to data table after committing to metadata table.
writeTableMetadata(table, compactionCommitTime, metadata,
context.emptyHoodieData());
- LOG.info("Committing Compaction {}. Finished with result {}",
compactionCommitTime, metadata);
+ LOG.info("Committing Compaction {}", compactionCommitTime);
+ LOG.debug("Compaction {} finished with result: {}",
compactionCommitTime, metadata);
CompactHelpers.getInstance().completeInflightCompaction(table,
compactionCommitTime, metadata);
} finally {
this.txnManager.endTransaction(Option.of(compactionInstant));
@@ -388,7 +389,8 @@ public abstract class BaseHoodieTableServiceClient<I, T, O>
extends BaseHoodieCl
finalizeWrite(table, logCompactionCommitTime, writeStats);
// commit to data table after committing to metadata table.
writeTableMetadata(table, logCompactionCommitTime, metadata,
context.emptyHoodieData());
- LOG.info("Committing Log Compaction {}. Finished with result {}",
logCompactionCommitTime, metadata);
+ LOG.info("Committing Log Compaction {}", logCompactionCommitTime);
+ LOG.debug("Log Compaction {} finished with result {}",
logCompactionCommitTime, metadata);
CompactHelpers.getInstance().completeInflightLogCompaction(table,
logCompactionCommitTime, metadata);
} finally {
this.txnManager.endTransaction(Option.of(logCompactionInstant));
@@ -513,7 +515,8 @@ public abstract class BaseHoodieTableServiceClient<I, T, O>
extends BaseHoodieCl
// Update table's metadata (table)
writeTableMetadata(table, clusteringInstant.getTimestamp(), metadata,
writeStatuses.orElseGet(context::emptyHoodieData));
- LOG.info("Committing Clustering {}. Finished with result {}",
clusteringCommitTime, metadata);
+ LOG.info("Committing Clustering {}", clusteringCommitTime);
+ LOG.debug("Clustering {} finished with result {}", clusteringCommitTime,
metadata);
table.getActiveTimeline().transitionReplaceInflightToComplete(
clusteringInstant,