always reset row iter when iterator used

2023-07-05 07:48:11 +00:00
parent 5f04d8ee95
commit cea8a51d2b
1 changed files with 3 additions and 1 deletions
--- a/src/sql/engine/pdml/static/ob_pdml_op_data_driver.cpp
+++ b/src/sql/engine/pdml/static/ob_pdml_op_data_driver.cpp
@ -251,8 +251,10 @@ int ObPDMLOpDataDriver::write_partitions(ObExecContext &ctx)
        // nop
      } else if (OB_FAIL(writer_->write_rows(ctx, tablet_loc, *row_iter))) {
        LOG_WARN("fail write rows", K(tablet_id), K(ret));
-      } else {
+      }
+      if (NULL != row_iter) {
        row_iter->close();
+        row_iter = NULL;
      }
    }
  }