(hudi) branch master updated: [Hudi-9475] Fix invalid log file name exception during CDC query (#13373)

[danny0405]

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 ed6f6928895 [Hudi-9475] Fix invalid log file name exception during CDC 
query (#13373)
ed6f6928895 is described below

commit ed6f6928895172bd1aed3bb2c8650aa330ee3316
Author: mrzhao <imrz...@qq.com>
AuthorDate: Fri May 30 08:39:01 2025 +0800

    [Hudi-9475] Fix invalid log file name exception during CDC query (#13373)
---
 .../main/java/org/apache/hudi/common/table/cdc/HoodieCDCFileSplit.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCFileSplit.java
 
b/hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCFileSplit.java
index f992a9b228c..d5be88bfeae 100644
--- 
a/hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCFileSplit.java
+++ 
b/hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCFileSplit.java
@@ -97,7 +97,8 @@ public class HoodieCDCFileSplit implements Serializable, 
Comparable<HoodieCDCFil
     this.instant = instant;
     this.cdcInferCase = cdcInferCase;
     this.cdcFiles = cdcFiles.stream()
-        
.sorted(Comparator.comparingInt(FSUtils::getFileVersionFromLog)).collect(Collectors.toList());
+        .sorted(Comparator.comparingInt(path -> 
FSUtils.getFileVersionFromLog(FSUtils.getFileNameFromPath(path))))
+        .collect(Collectors.toList());
     this.beforeFileSlice = beforeFileSlice;
     this.afterFileSlice = afterFileSlice;
   }