diff --git a/src/sql/engine/px/exchange/ob_px_ms_coord_op.cpp b/src/sql/engine/px/exchange/ob_px_ms_coord_op.cpp index ad41b01313..a3a0098f51 100644 --- a/src/sql/engine/px/exchange/ob_px_ms_coord_op.cpp +++ b/src/sql/engine/px/exchange/ob_px_ms_coord_op.cpp @@ -151,6 +151,7 @@ int ObPxMSCoordOp::inner_rescan() finish_ch_cnt_ = 0; all_rows_finish_ = false; destroy_readers(); + row_heap_.reset_heap(); int ret = ObPxCoordOp::inner_rescan(); return ret; }