-
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
feature: Saga support customize whether update last retry log #3372
feature: Saga support customize whether update last retry log #3372
Conversation
Codecov Report
@@ Coverage Diff @@
## develop #3372 +/- ##
=============================================
- Coverage 51.58% 51.57% -0.02%
- Complexity 3333 3340 +7
=============================================
Files 616 616
Lines 20198 20233 +35
Branches 2531 2535 +4
=============================================
+ Hits 10420 10435 +15
- Misses 8734 8751 +17
- Partials 1044 1047 +3
|
…e_persist_retryInst_log
…e_persist_retryInst_log
...aga-engine-store/src/main/java/io/seata/saga/engine/store/db/DbAndReportTcStateLogStore.java
Outdated
Show resolved
Hide resolved
...aga-engine-store/src/main/java/io/seata/saga/engine/store/db/DbAndReportTcStateLogStore.java
Outdated
Show resolved
Hide resolved
...aga-engine-store/src/main/java/io/seata/saga/engine/store/db/DbAndReportTcStateLogStore.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
saga/seata-saga-engine-store/src/main/java/io/seata/saga/engine/store/db/StateLogStoreSqls.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
...seata-saga-statelang/src/main/java/io/seata/saga/statelang/domain/impl/StateMachineImpl.java
Outdated
Show resolved
Hide resolved
...seata-saga-statelang/src/main/java/io/seata/saga/statelang/domain/impl/StateMachineImpl.java
Outdated
Show resolved
Hide resolved
...pring-boot-starter/src/main/resources/META-INF/additional-spring-configuration-metadata.json
Outdated
Show resolved
Hide resolved
...pring-boot-starter/src/main/resources/META-INF/additional-spring-configuration-metadata.json
Outdated
Show resolved
Hide resolved
saga/seata-saga-statelang/src/main/java/io/seata/saga/statelang/domain/StateMachine.java
Outdated
Show resolved
Hide resolved
saga/seata-saga-statelang/src/main/java/io/seata/saga/statelang/domain/ServiceTaskState.java
Outdated
Show resolved
Hide resolved
...aga-engine-store/src/main/java/io/seata/saga/engine/store/db/DbAndReportTcStateLogStore.java
Outdated
Show resolved
Hide resolved
80444c2
to
ce7e216
Compare
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
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
Ⅰ. Describe what this PR did
add config for saga, support customize whether update last retry log
提供配置,可自定义正向重试和反向补偿重试的日志存储策略,支持在上一次重试日志的基础上,做更新操作
提供全局配置参数:client.rm.sagaRetryPersistModeUpdate、client.rm.sagaCompensatePersistModeUpdate,默认为 false
提供状态机级别、单个状态节点配置参数:retryPersistModeUpdate、compensatePersistModeUpdate,默认为 false
当 client.rm.sagaRetryPersistModeUpdate 或 retryPersistModeUpdate 配置为true时,当前事务节点的重试,基于当前需要重试的事务日志做更新,而不是新增一条重试日志(compensate 参数同理)
Ⅱ. Does this pull request fix one issue?
fixes #3394
Ⅲ. Why don't you add test cases (unit test/integration test)?
Ⅳ. Describe how to verify it
Ⅴ. Special notes for reviews