yuzelin opened a new pull request, #9048:
URL: https://github.com/apache/paimon/pull/9048

   ### Purpose
   ncremental diff queries compare data between two tags bucket by bucket. For 
postpone-bucket tables, the configured bucket value remains -2, while the 
actual bucket number of a partition may change between the two snapshots. In 
that case, directly performing the bucket-based diff may produce incorrect 
results.
   
   So this PR collects the actual bucket number of each partition from both 
snapshots and check if they are equal. If not, fall back to Spark except query.
   ### Tests
   IncrementalTableTest
   TableValuedFunctionsTest


-- 
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