amoro
amoro copied to clipboard
[ARCTIC-393][AMS]Improve the high concurrency processing capability of the allocateTransactionId interface
Why are the changes needed?
resolve #393 When multiple tasks(like upsert partial fields of arctic table with Flink) write data to the same table, apply for TransActionID at the same time. So we should improve the high concurrency processing capability of the allocateTransactionId interface.
Brief change log
add table lock in ArcticTransactionService
How was this patch tested?
-
[ ] Add some test cases that check the changes thoroughly including negative and positive cases if possible
-
[ ] Add screenshots for manual tests if appropriate
-
[x] Run test locally before making a pull request
Documentation
- Does this pull request introduces a new feature? (no)
- If yes, how is the feature documented? (not documented)