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 934082f52587d06965fdf790727f8b5265f918eb..a5b78c89cce6c5de05447d58325afd5eb0d86d46 100644 --- a/src/sql/engine/px/exchange/ob_px_receive_op.cpp +++ b/src/sql/engine/px/exchange/ob_px_receive_op.cpp @@ -528,7 +528,7 @@ int ObPxReceiveOp::wrap_get_next_batch(const int64_t max_row_cnt) brs_.end_ = idx < max_cnt; // set project flag to prevent duplcated expression calculation if (NULL != all_exprs) { - FOREACH_CNT(e, spec_.calc_exprs_) { + FOREACH_CNT(e, *(all_exprs)) { (*e)->get_eval_info(eval_ctx_).projected_ = 1; } }