[PR] [tiering] fix flink tiering duplicate write result [fluss]

["zuston (via GitHub)" <gi...@apache.org>]

zuston opened a new pull request, #3608:
URL: https://github.com/apache/fluss/pull/3608

   ### Purpose
   
   Linked issue: close #3562 
   
   This PR fixes duplicate tiering write results caused by slow split generation.
   
   When split generation takes a long time, the source enumerator may hold a requested table epoch without reporting it as an active tiering epoch. If the tiering trigger interval is short, the coordinator can assign the same table again with a new epoch before the previous round finishes generating and processing splits. The committer then may receive write results from two rounds of the same table and detect duplicate bucket results.
   
   ### Brief change log
   
   <!-- Please describe the changes made in this pull request and explain how they address the issue -->
   
   ### Tests
   
   <!-- List UT and IT cases to verify this change -->
   
   ### API and Format
   
   <!-- Does this change affect API or storage format -->
   
   ### Documentation
   
   <!-- Does this change introduce a new feature -->
   


-- 
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: issues-unsubscribe@fluss.apache.org

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

Re: [PR] [tiering] fix flink tiering duplicate write result [fluss]

["luoyuxia (via GitHub)" <gi...@apache.org>]

luoyuxia merged PR #3608:
URL: https://github.com/apache/fluss/pull/3608


-- 
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: issues-unsubscribe@fluss.apache.org

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