File tree Expand file tree Collapse file tree 2 files changed +10
-0
lines changed Expand file tree Collapse file tree 2 files changed +10
-0
lines changed Original file line number Diff line number Diff line change @@ -329,6 +329,7 @@ Status RPC::SendRequest(const EndPoint& endpoint,
329329
330330 // the errno of need retry
331331 if (response.error ().errcode () != pb::error::EINTERNAL &&
332+ response.error ().errcode () != pb::error::EREQUEST_FULL &&
332333 response.error ().errcode () != pb::error::EBACKEND_STORE) {
333334 break ;
334335 }
Original file line number Diff line number Diff line change @@ -251,6 +251,10 @@ static inline Status TransformStatus(const dingodb::sdk::Status& status) {
251251 g_txn_memlock_conflict_per_second << 1 ;
252252 return Status (pb::error::ESTORE_MAYBE_RETRY, status.ToString ());
253253
254+ } else if (status.IsPushMinCommitTs ()) {
255+ g_txn_total_conflict_per_second << 1 ;
256+ return Status (pb::error::ESTORE_MAYBE_RETRY, status.ToString ());
257+
254258 } else {
255259 return Status (pb::error::EBACKEND_STORE, status.ToString ());
256260 }
@@ -501,6 +505,11 @@ Status DingodbTxn::TransformStatus(const dingodb::sdk::Status& status) {
501505 txn_trace_.is_conflict = true ;
502506 return Status (pb::error::ESTORE_MAYBE_RETRY, status.ToString ());
503507
508+ } else if (status.IsPushMinCommitTs ()) {
509+ g_txn_total_conflict_per_second << 1 ;
510+ txn_trace_.is_conflict = true ;
511+ return Status (pb::error::ESTORE_MAYBE_RETRY, status.ToString ());
512+
504513 } else {
505514 return Status (pb::error::EBACKEND_STORE, status.ToString ());
506515 }
You can’t perform that action at this time.
0 commit comments