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 51b57330a8e9 refactor(examples): use SLF4J parameterized logging
instead of string concatenation (#19187)
51b57330a8e9 is described below
commit 51b57330a8e93c30b39a721e5da8aa9dec7619b3
Author: voonhous <[email protected]>
AuthorDate: Sun Jul 5 04:37:30 2026 +0800
refactor(examples): use SLF4J parameterized logging instead of string
concatenation (#19187)
---
.../org/apache/hudi/examples/spark/HoodieWriteClientExample.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/hudi-examples/hudi-examples-spark/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java
b/hudi-examples/hudi-examples-spark/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java
index e4300af3c5ef..1f431563aa5f 100644
---
a/hudi-examples/hudi-examples-spark/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java
+++
b/hudi-examples/hudi-examples-spark/src/main/java/org/apache/hudi/examples/spark/HoodieWriteClientExample.java
@@ -101,7 +101,7 @@ public class HoodieWriteClientExample {
// inserts
String newCommitTime = client.startCommit();
- log.info("Starting commit " + newCommitTime);
+ log.info("Starting commit {}", newCommitTime);
List<HoodieRecord<HoodieAvroPayload>> records =
dataGen.generateInserts(newCommitTime, 10);
List<HoodieRecord<HoodieAvroPayload>> recordsSoFar = new
ArrayList<>(records);
@@ -110,7 +110,7 @@ public class HoodieWriteClientExample {
// updates
newCommitTime = client.startCommit();
- log.info("Starting commit " + newCommitTime);
+ log.info("Starting commit {}", newCommitTime);
List<HoodieRecord<HoodieAvroPayload>> toBeUpdated =
dataGen.generateUpdates(newCommitTime, 2);
records.addAll(toBeUpdated);
recordsSoFar.addAll(toBeUpdated);
@@ -119,7 +119,7 @@ public class HoodieWriteClientExample {
// Delete
newCommitTime = client.startCommit();
- log.info("Starting commit " + newCommitTime);
+ log.info("Starting commit {}", newCommitTime);
// just delete half of the records
int numToDelete = recordsSoFar.size() / 2;
List<HoodieKey> toBeDeleted =
recordsSoFar.stream().map(HoodieRecord::getKey).limit(numToDelete).collect(Collectors.toList());
@@ -128,7 +128,7 @@ public class HoodieWriteClientExample {
// Delete by partition
newCommitTime =
client.startCommit(HoodieTimeline.REPLACE_COMMIT_ACTION);
- log.info("Starting commit " + newCommitTime);
+ log.info("Starting commit {}", newCommitTime);
// The partition where the data needs to be deleted
List<String> partitionList = toBeDeleted.stream().map(s ->
s.getPartitionPath()).distinct().collect(Collectors.toList());
List<String> deleteList = recordsSoFar.stream().filter(f ->
!partitionList.contains(f.getPartitionPath()))
