Re: [I] [SUPPORT] CDC file clean not work [hudi]

[via GitHub]

zealjoanna commented on issue #9557:
URL: https://github.com/apache/hudi/issues/9557#issuecomment-1751572036

   > @zealjoanna Do you still have spare time for contributing the fix ?
   
   
   
   > 
![image](https://user-images.githubusercontent.com/21325163/263876807-eff4cfbd-e140-4f93-bc60-5a072569fe1e.png)
 the cdc file contains the partition_path while the parquet file use the 
filename i guess that's the point
   
   if (cdcPathAndSizes != null && !cdcPathAndSizes.isEmpty()) {
     for (Map.Entry<String, Long> cdcEntry : cdcPathAndSizes.entrySet()) {
       String mapKey = FSUtils.getFileName(cdcEntry.getKey(),
           partitionStatName);
       Long mapValue = cdcEntry.getValue();
       map.put(mapKey, mapValue);
     }
   }
   
   this fix works 


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@hudi.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org