This is an automated email from the ASF dual-hosted git repository. voonhous pushed a commit to branch release-1.2.1 in repository https://gitbox.apache.org/repos/asf/hudi.git
commit 16cdb7dc90cc6db030cbe29d4dae6b37e578cb5e Author: voonhous <[email protected]> AuthorDate: Sun Jul 5 04:27:35 2026 +0800 refactor(aws): use SLF4J parameterized logging instead of string concatenation (#19186) (cherry picked from commit 60a3e9a9695795aaa2c662feabd3a33b2975a59a) --- .../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;
