master branch place_holder

src/sql/das/ob_das_insert_op.cpp

@@ -474,7 +474,8 @@ ObDASInsertResult::ObDASInsertResult()
     result_buffer_(),
     result_newrow_iter_(),
     output_types_(nullptr),
-    is_duplicated_(false)
+    is_duplicated_(false),
+    response_snapshot_()
 {
 }
 
@@ -571,7 +572,8 @@ int ObDASInsertResult::reuse()
 OB_SERIALIZE_MEMBER((ObDASInsertResult, ObIDASTaskResult),
                     affected_rows_,
                     result_buffer_,
-                    is_duplicated_);
+                    is_duplicated_,
+                    response_snapshot_);
 
 
 void ObDASConflictIterator::reset()

src/sql/das/ob_das_insert_op.h

@@ -130,6 +130,7 @@ public:
 
   bool is_duplicated() { return is_duplicated_; }
   void set_is_duplicated(bool is_duplicated) { is_duplicated_ = is_duplicated; }
+  transaction::ObTxReadSnapshot &get_response_snapshot() { return response_snapshot_; }
 
   INHERIT_TO_STRING_KV("ObIDASTaskResult", ObIDASTaskResult,
                         K_(affected_rows));
@@ -139,6 +140,7 @@ private:
   ObDASWriteBuffer::NewRowIterator result_newrow_iter_;
   const ObjMetaFixedArray *output_types_;
   bool is_duplicated_;
+  transaction::ObTxReadSnapshot response_snapshot_;
 };
 }  // namespace sql
 }  // namespace oceanbase