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 cbd2573bdeb [MINOR] Improve performance of generateBucketKey (#11748)
cbd2573bdeb is described below
commit cbd2573bdeb2de97aba77f5ba9702c87f26e4ab7
Author: Sergey Troshkov <[email protected]>
AuthorDate: Sat Aug 10 08:11:43 2024 +0700
[MINOR] Improve performance of generateBucketKey (#11748)
Co-authored-by: Sergey Troshkov <[email protected]>
---
.../hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
index 4edc3c04bac..883065e9ba8 100644
---
a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
+++
b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java
@@ -314,7 +314,7 @@ public class StreamerUtil {
* Generates the bucket ID using format {partition path}_{fileID}.
*/
public static String generateBucketKey(String partitionPath, String fileId) {
- return String.format("%s_%s", partitionPath, fileId);
+ return partitionPath + "_" + fileId;
}
/**
