[CP] Fix DtlIntermRes dynamic memleak

2022-12-07 14:38:18 +00:00
parent 62901dea20
commit c765ae7b31
1 changed files with 1 additions and 1 deletions
--- a/src/sql/engine/px/ob_px_coord_op.cpp
+++ b/src/sql/engine/px/ob_px_coord_op.cpp
@ -1008,7 +1008,7 @@ int ObPxCoordOp::batch_rescan()
 int ObPxCoordOp::erase_dtl_interm_result()
 {
  int ret = OB_SUCCESS;
-  if (enable_px_batch_rescan()) {
+  if (static_cast<const ObPxCoordSpec&>(get_spec()).batch_op_info_.is_inited()) {
    ObDTLIntermResultKey key;
    ObDtlChannelInfo ci;
    // no need OB_SUCCESS in for-loop.