[Improvement][AMS]: Improve the high concurrency processing capability of the allocateTransactionId interface

[hameizi]

Search before asking

• I have searched in the issues and found no similar issues.

What would you like to be improved?

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.

How should we improve?

we can compare the old and new transactionid when update row in mysql, like update table_metadata where tablename={} and current_tx_id={old_tx_id}. And we get the update return value(Number of rows affected), if the value greater than 0 means update success else retry more(just like cas).

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct