diff --git a/src/sql/engine/cmd/ob_load_data_impl.cpp b/src/sql/engine/cmd/ob_load_data_impl.cpp index 0db356f8ae..b978c31660 100644 --- a/src/sql/engine/cmd/ob_load_data_impl.cpp +++ b/src/sql/engine/cmd/ob_load_data_impl.cpp @@ -1955,8 +1955,10 @@ int ObLoadDataSPImpl::execute(ObExecContext &ctx, ObLoadDataStmt &load_stmt) while (OB_SUCC(ret) && !box.read_cursor.is_end_file() && box.data_trimer.get_lines_count() < box.ignore_rows) { + box.temp_handle->data_buffer->reset(); OZ (next_file_buffer(ctx, box, box.temp_handle, box.ignore_rows - box.data_trimer.get_lines_count())); + OZ (ObLoadDataUtils::check_session_status(*ctx.get_my_session())); LOG_DEBUG("LOAD DATA ignore rows", K(box.ignore_rows), K(box.data_trimer.get_lines_count())); }