You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2023/06/10 14:56:40 UTC
[doris] 09/10: [Fix](2PC) fix timeout config is not avaible for commit phase in 2pc (#20423)
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 7b7a2619a56f2eba80996c4c70dd337432047126
Author: GoGoWen <82...@users.noreply.github.com>
AuthorDate: Fri Jun 9 09:33:58 2023 +0800
[Fix](2PC) fix timeout config is not avaible for commit phase in 2pc (#20423)
fix config::txn_commit_rpc_timeout_ms is not available for commit phase in 2pc.
---
.../src/main/java/org/apache/doris/service/FrontendServiceImpl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
index 4be9605815..638f172660 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
@@ -786,8 +786,9 @@ public class FrontendServiceImpl implements FrontendService.Iface {
}
if (txnOperation.equalsIgnoreCase("commit")) {
+ long timeoutMs = request.isSetThriftRpcTimeoutMs() ? request.getThriftRpcTimeoutMs() / 2 : 5000;
Env.getCurrentGlobalTransactionMgr()
- .commitTransaction2PC(database, tableList, request.getTxnId(), 5000);
+ .commitTransaction2PC(database, tableList, request.getTxnId(), timeoutMs);
} else if (txnOperation.equalsIgnoreCase("abort")) {
Env.getCurrentGlobalTransactionMgr().abortTransaction2PC(database.getId(), request.getTxnId(), tableList);
} else {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org