HuangZhenQiu opened a new issue, #19207:
URL: https://github.com/apache/hudi/issues/19207

   ### Bug Description
   
   **What happened:**
   When we evaluate the Flink upsert internally, we find that the 
GlobalRecordIndexPartitioner get numFileGroupsForRecordIndexPartition = 8. It 
is different with the totally number of file groups in the record index 
partition. 
   
   **What you expected:**
   getNumFileGroupsForRecordIndexPartition in GlobalRecordIndexPartitioner 
should get the correct totally number of file groups correctly, rather than use 
the getPartitionFileSlices that returns Get the latest file slices for a given 
partition the in org.apache.hudi.metadata.HoodieTableMetadataUtil.
   
   **Steps to reproduce:**
   1. Bootstrap a new table from a COW original table
   2. Setup an Flink upsert job in MOR mode
   3. Check the getNumFileGroupsForRecordIndexPartition in 
GlobalRecordIndexPartitioner.
   
   
   ### Environment
   
   **Hudi version:**
   **Query engine:** (Spark/Flink/Trino etc)
   **Relevant configs:**
   
   
   ### Logs and Stack Trace
   
   _No response_


-- 
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: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to