-
Notifications
You must be signed in to change notification settings - Fork 8.7k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
optimize: commit/rollback retry timeout event #4391
Conversation
@Bughue please add change log and add global transaction status Desc in https://seata.io/zh-cn/docs/user/appendix/global-transaction-status.html |
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM. 请在changes目录下的两份1.5.0.md中进行pr和作者登记
对于此pr后续扩展想法,进行changestatus为xxxxRetryTimeout,不要再有remove动作
异步补偿定时任务不应该补偿这类状态,未来交由控制台,或者用户手动接入后从数据库删除
Codecov Report
@@ Coverage Diff @@
## develop #4391 +/- ##
=============================================
+ Coverage 48.99% 49.02% +0.02%
- Complexity 3956 3961 +5
=============================================
Files 733 733
Lines 24988 24999 +11
Branches 3093 3093
=============================================
+ Hits 12244 12256 +12
+ Misses 11448 11446 -2
- Partials 1296 1297 +1
|
…op-retrytimeout # Conflicts: # changes/1.5.0.md # changes/en-us/1.5.0.md
server/src/main/java/io/seata/server/session/SessionHelper.java
Outdated
Show resolved
Hide resolved
server/src/main/java/io/seata/server/session/SessionHelper.java
Outdated
Show resolved
Hide resolved
server/src/main/java/io/seata/server/session/SessionHelper.java
Outdated
Show resolved
Hide resolved
server/src/main/java/io/seata/server/coordinator/DefaultCoordinator.java
Outdated
Show resolved
Hide resolved
server/src/main/java/io/seata/server/session/SessionHelper.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
eventBus.post(new GlobalTransactionEvent(globalSession.getTransactionId(), GlobalTransactionEvent.ROLE_TC, | ||
globalSession.getTransactionName(), globalSession.getApplicationId(), globalSession.getTransactionServiceGroup(), | ||
globalSession.getBeginTime(), null, globalSession.getStatus())); | ||
SessionHelper.postTcSessionBeginEvent(globalSession); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
postTcSessionBeginEvent
is not appropriate here.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
optimize the method naming.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
will optimize later
globalSession.getApplicationId(), | ||
globalSession.getTransactionServiceGroup(), globalSession.getBeginTime(), | ||
null, globalSession.getStatus())); | ||
SessionHelper.postTcSessionBeginEvent(globalSession); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
postTcSessionBeginEvent
is not appropriate here.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
will optimize later
Ⅰ. Describe what this PR did
全局事务commit/rollback在MAX_ROLLBACK_RETRY_TIMEOUT或者MAX_COMMIT_RETRY_TIMEOUT之后发出eventBus,新增状态CommitRetryTimeout和RollbackRetryTimeout
Ⅱ. Does this pull request fix one issue?
#4387
Ⅲ. Why don't you add test cases (unit test/integration test)?
Ⅳ. Describe how to verify it
Ⅴ. Special notes for reviews