(hudi) branch master updated: refactor(aws): use SLF4J parameterized logging instead of string concatenation (#19186)

[yihua]

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

yihua 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 60a3e9a96957 refactor(aws): use SLF4J parameterized logging instead of 
string concatenation (#19186)
60a3e9a96957 is described below

commit 60a3e9a9695795aaa2c662feabd3a33b2975a59a
Author: voonhous <voonho...@gmail.com>
AuthorDate: Sun Jul 5 04:27:35 2026 +0800

    refactor(aws): use SLF4J parameterized logging instead of string 
concatenation (#19186)
---
 .../java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java   | 8 ++++----
 .../src/main/java/org/apache/hudi/aws/utils/DynamoTableUtils.java | 4 ++--
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java 
b/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java
index 10f0b5a1592d..eb0a50ca0638 100644
--- 
a/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java
+++ 
b/hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java
@@ -252,7 +252,7 @@ public class AWSGlueCatalogSyncClient extends 
HoodieSyncClient {
   @Override
   public List<Partition> getPartitionsFromList(String tableName, List<String> 
partitionList) {
     if (partitionList.isEmpty()) {
-      log.info("No partitions to read for " + tableId(this.databaseName, 
tableName));
+      log.info("No partitions to read for {}", tableId(this.databaseName, 
tableName));
       return Collections.emptyList();
     }
     HoodieTimer timer = HoodieTimer.start();
@@ -310,7 +310,7 @@ public class AWSGlueCatalogSyncClient extends 
HoodieSyncClient {
     HoodieTimer timer = HoodieTimer.start();
     try {
       if (partitionsToAdd.isEmpty()) {
-        log.info("No partitions to add for " + tableId(this.databaseName, 
tableName));
+        log.info("No partitions to add for {}", tableId(this.databaseName, 
tableName));
         return;
       }
       Table table = getTable(awsGlue, databaseName, tableName);
@@ -373,7 +373,7 @@ public class AWSGlueCatalogSyncClient extends 
HoodieSyncClient {
     HoodieTimer timer = HoodieTimer.start();
     try {
       if (changedPartitions.isEmpty()) {
-        log.info("No partitions to update for " + tableId(this.databaseName, 
tableName));
+        log.info("No partitions to update for {}", tableId(this.databaseName, 
tableName));
         return;
       }
       Table table = getTable(awsGlue, databaseName, tableName);
@@ -413,7 +413,7 @@ public class AWSGlueCatalogSyncClient extends 
HoodieSyncClient {
     HoodieTimer timer = HoodieTimer.start();
     try {
       if (partitionsToDrop.isEmpty()) {
-        log.info("No partitions to drop for " + tableId(this.databaseName, 
tableName));
+        log.info("No partitions to drop for {}", tableId(this.databaseName, 
tableName));
         return;
       }
       parallelizeChange(partitionsToDrop, this.changeParallelism, partitions 
-> this.dropPartitionsInternal(tableName, partitions), 
MAX_DELETE_PARTITIONS_PER_REQUEST);
diff --git 
a/hudi-aws/src/main/java/org/apache/hudi/aws/utils/DynamoTableUtils.java 
b/hudi-aws/src/main/java/org/apache/hudi/aws/utils/DynamoTableUtils.java
index ace74a1fbc79..1a70419c79d0 100644
--- a/hudi-aws/src/main/java/org/apache/hudi/aws/utils/DynamoTableUtils.java
+++ b/hudi-aws/src/main/java/org/apache/hudi/aws/utils/DynamoTableUtils.java
@@ -222,7 +222,7 @@ public class DynamoTableUtils {
       return true;
     } catch (final ResourceInUseException e) {
       if (log.isTraceEnabled()) {
-        log.trace("Table " + createTableRequest.tableName() + " already 
exists", e);
+        log.trace("Table {} already exists", createTableRequest.tableName(), 
e);
       }
     }
     return false;
@@ -240,7 +240,7 @@ public class DynamoTableUtils {
       return true;
     } catch (final ResourceNotFoundException e) {
       if (log.isTraceEnabled()) {
-        log.trace("Table " + deleteTableRequest.tableName() + " does not 
exist", e);
+        log.trace("Table {} does not exist", deleteTableRequest.tableName(), 
e);
       }
     }
     return false;