This is an automated email from the ASF dual-hosted git repository.
liaoxin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new e7eb78d056d [enhance](transaction) support abort transaction when
coordinate be down in cloud mode (#59240)
e7eb78d056d is described below
commit e7eb78d056dadcb4468555123b14a3e97aa4a547
Author: hui lai <[email protected]>
AuthorDate: Tue Dec 23 14:53:41 2025 +0800
[enhance](transaction) support abort transaction when coordinate be down in
cloud mode (#59240)
### What problem does this PR solve?
Support abort transaction when coordinate be down in cloud mode for
transactions can be aborted timely in VCG failover scene.
---
.../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 d3767ebdc88..aff9458f73b 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
@@ -2137,7 +2137,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]
