diff --git a/src/sql/engine/pdml/static/ob_pdml_op_data_driver.h b/src/sql/engine/pdml/static/ob_pdml_op_data_driver.h
index 443ed00bf6..dfd57f742d 100644
--- a/src/sql/engine/pdml/static/ob_pdml_op_data_driver.h
+++ b/src/sql/engine/pdml/static/ob_pdml_op_data_driver.h
@@ -90,6 +90,9 @@ private:
     ~ReturningCtx() = default;
     void reset()
     {
+      if (row_iter_) {
+        row_iter_->close();
+      }
       tablet_id_array_.reset();
       next_idx_ = 0;
       row_iter_ = NULL;