This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 2ec1a6a7e71 [fix](group commit) Modify group commit commit/abort txn
timeout as stream load (#39003) (#39069)
2ec1a6a7e71 is described below
commit 2ec1a6a7e71cafc566beb50ef0c57835c36d1236
Author: meiyi <[email protected]>
AuthorDate: Thu Aug 8 14:36:29 2024 +0800
[fix](group commit) Modify group commit commit/abort txn timeout as stream
load (#39003) (#39069)
pick https://github.com/apache/doris/pull/39003
---
be/src/olap/wal/wal_table.cpp | 9 +++------
be/src/runtime/group_commit_mgr.cpp | 6 +++---
2 files changed, 6 insertions(+), 9 deletions(-)
diff --git a/be/src/olap/wal/wal_table.cpp b/be/src/olap/wal/wal_table.cpp
index e57bf29a1c9..e45157626a0 100644
--- a/be/src/olap/wal/wal_table.cpp
+++ b/be/src/olap/wal/wal_table.cpp
@@ -172,8 +172,7 @@ Status WalTable::_try_abort_txn(int64_t db_id, std::string&
label) {
master_addr.hostname, master_addr.port,
[&request, &result](FrontendServiceConnection& client) {
client->loadTxnRollback(result, request);
- },
- 10000L);
+ });
auto result_status = Status::create<false>(result.status);
LOG(INFO) << "abort label " << label << ", st:" << st << ",
result_status:" << result_status;
return result_status;
@@ -193,10 +192,8 @@ Status WalTable::_replay_wal_internal(const std::string&
wal) {
[[maybe_unused]] auto st = _try_abort_txn(_db_id, label);
}
#endif
- DBUG_EXECUTE_IF("WalTable.replay_wals.stop", {
- // LOG(INFO) << "WalTable.replay_wals.stop";
- return Status::InternalError("WalTable.replay_wals.stop");
- });
+ DBUG_EXECUTE_IF("WalTable.replay_wals.stop",
+ { return
Status::InternalError("WalTable.replay_wals.stop"); });
return _replay_one_wal_with_streamload(wal_id, wal, label);
}
diff --git a/be/src/runtime/group_commit_mgr.cpp
b/be/src/runtime/group_commit_mgr.cpp
index 52a14f159a6..d97b268fc27 100644
--- a/be/src/runtime/group_commit_mgr.cpp
+++ b/be/src/runtime/group_commit_mgr.cpp
@@ -408,6 +408,7 @@ Status GroupCommitTable::_finish_group_commit_load(int64_t
db_id, int64_t table_
request.__set_db_id(db_id);
request.__set_table_id(table_id);
request.__set_txnId(txn_id);
+ request.__set_thrift_rpc_timeout_ms(config::txn_commit_rpc_timeout_ms);
request.__set_groupCommit(true);
request.__set_receiveBytes(state->num_bytes_load_total());
if (_exec_env->master_info()->__isset.backend_id) {
@@ -425,7 +426,7 @@ Status GroupCommitTable::_finish_group_commit_load(int64_t
db_id, int64_t table_
[&request, &result](FrontendServiceConnection& client) {
client->loadTxnCommit(result, request);
},
- 10000L);
+ config::txn_commit_rpc_timeout_ms);
result_status = Status::create(result.status);
DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.commit_success_and_rpc_error",
{ result_status =
Status::InternalError("commit_success_and_rpc_error"); });
@@ -442,8 +443,7 @@ Status GroupCommitTable::_finish_group_commit_load(int64_t
db_id, int64_t table_
master_addr.hostname, master_addr.port,
[&request, &result](FrontendServiceConnection& client) {
client->loadTxnRollback(result, request);
- },
- 10000L);
+ });
result_status = Status::create<false>(result.status);
DBUG_EXECUTE_IF("LoadBlockQueue._finish_group_commit_load.err_status",
{
std ::string msg = "abort txn";
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
