From ab007e88689a837cd29699b3796abcb03703d378 Mon Sep 17 00:00:00 2001 From: tino247 Date: Mon, 17 Jul 2023 06:12:15 +0000 Subject: [PATCH] Fix ls rpc table core --- src/share/ls/ob_rpc_ls_table.cpp | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/src/share/ls/ob_rpc_ls_table.cpp b/src/share/ls/ob_rpc_ls_table.cpp index 94245841e9..4db7db3069 100644 --- a/src/share/ls/ob_rpc_ls_table.cpp +++ b/src/share/ls/ob_rpc_ls_table.cpp @@ -298,6 +298,15 @@ int ObRpcLSTable::do_detect_master_rs_ls_( if (OB_TMP_FAIL(proxy.wait_all(return_ret_array))) { // ignore ret LOG_WARN("wait batch result failed", KR(tmp_ret), KR(ret)); ret = OB_SUCC(ret) ? tmp_ret : ret; + } else if (proxy.get_dests().count() != proxy.get_args().count() + || return_ret_array.count() != proxy.get_args().count() + || return_ret_array.count() != proxy.get_results().count()) { + ret = OB_STATE_NOT_MATCH; + LOG_WARN("args/dest/return_ret_array/results count not match, need retry", + KR(ret), "args_cnt", proxy.get_args().count(), + "dests_cnt", proxy.get_dests().count(), + "return_cnt", return_ret_array.count(), + "result_cnt", proxy.get_results().count()); } bool leader_exist = false; for (int64_t i = 0; OB_SUCC(ret) && i < return_ret_array.count(); i++) {