Fix winfunc single partition parallel error result

2024-03-15 10:45:29 +00:00
parent 51cf0b2083
commit 2a4c64d7b2
3 changed files with 15 additions and 17 deletions
--- a/src/sql/engine/window_function/ob_window_function_op.cpp
+++ b/src/sql/engine/window_function/ob_window_function_op.cpp
@ -2635,7 +2635,8 @@ int ObWindowFunctionOp::get_whole_msg(bool is_end,
      }
    }
    if (OB_SUCC(ret)) {
-      if (OB_FAIL(proxy.get_dh_msg(MY_SPEC.id_,
+      // Synchronization is requested here.
+      if (OB_FAIL(proxy.get_dh_msg_sync(MY_SPEC.id_,
          dtl::DH_WINBUF_WHOLE_MSG,
          piece,
          temp_whole_msg,