This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 2d99f3c2ab5 branch-4.0: [enhance](transaction) support abort
transaction when coordinate be down in cloud mode #59240 (#59285)
2d99f3c2ab5 is described below
commit 2d99f3c2ab51f1b70db061e80448aad387cbefc0
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Wed Dec 24 12:10:13 2025 +0800
branch-4.0: [enhance](transaction) support abort transaction when
coordinate be down in cloud mode #59240 (#59285)
Cherry-picked from #59240
Co-authored-by: hui lai <[email protected]>
---
.../doris/cloud/transaction/CloudGlobalTransactionMgr.java | 13 ++++++++++++-
1 file changed, 12 insertions(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
b/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
index 780ab8c41bc..3503ad78bbc 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/cloud/transaction/CloudGlobalTransactionMgr.java
@@ -2115,7 +2115,18 @@ public class CloudGlobalTransactionMgr implements
GlobalTransactionMgrIface {
@Override
public void abortTxnWhenCoordinateBeDown(long coordinateBeId, String
coordinateHost, int limit) {
- // do nothing in cloud mode
+ AbortTxnWithCoordinatorRequest.Builder builder =
AbortTxnWithCoordinatorRequest.newBuilder();
+ builder.setIp(coordinateHost);
+ builder.setId(coordinateBeId);
+ final AbortTxnWithCoordinatorRequest request = builder.build();
+ AbortTxnWithCoordinatorResponse response = null;
+ try {
+ response = MetaServiceProxy
+ .getInstance().abortTxnWithCoordinator(request);
+ LOG.info("AbortTxnWithCoordinatorResponse: {}", response);
+ } catch (RpcException e) {
+ LOG.warn("Abort txn on coordinate BE {} failed, msg={}",
coordinateHost, e.getMessage());
+ }
}
@Override
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
