From 0b0e5ecfb60172b34ff40ff56c0b07ef654de110 Mon Sep 17 00:00:00 2001
From: qingsuijiu <642782632@qq.com>
Date: Tue, 20 Aug 2024 04:54:21 +0000
Subject: [PATCH] Clear the calculation flag of ObPxMSCoordOp.

---
 src/sql/engine/px/exchange/ob_px_receive_op.cpp | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/sql/engine/px/exchange/ob_px_receive_op.cpp b/src/sql/engine/px/exchange/ob_px_receive_op.cpp
index aded4a26a3..8835a45d73 100644
--- a/src/sql/engine/px/exchange/ob_px_receive_op.cpp
+++ b/src/sql/engine/px/exchange/ob_px_receive_op.cpp
@@ -441,6 +441,7 @@ int ObPxReceiveOp::wrap_get_next_batch(const int64_t max_row_cnt)
 {
   const int64_t max_cnt = std::min(max_row_cnt, spec_.max_batch_size_);
   int ret = OB_SUCCESS;
+  clear_evaluated_flag();
   int64_t idx = 0;
   ObEvalCtx::BatchInfoScopeGuard batch_info_guard(eval_ctx_);
   batch_info_guard.set_batch_size(max_cnt);