Fix the issue that the error code was omitted in the bloom filter merge function

2023-05-18 04:46:34 +00:00
parent ce9f6b92fc
commit 33fa474ebd
1 changed files with 1 additions and 1 deletions
--- a/src/sql/engine/px/p2p_datahub/ob_runtime_filter_msg.cpp
+++ b/src/sql/engine/px/p2p_datahub/ob_runtime_filter_msg.cpp
@ -240,7 +240,7 @@ int ObRFBloomFilterMsg::process_msg_internal(bool &need_free)
    }
    // create whole bloom filter, no need wait
    if (OB_SUCC(ret)) {
-      if (map.atomic_refactored(dh_key, regen_call)) {
+      if (OB_FAIL(map.atomic_refactored(dh_key, regen_call))) {
        LOG_WARN("fail to update bloom filter msg", K(ret));
      }
    }