提交 6e9e639a 编写于 作者: Y yishenglanlingzui 提交者: wangzelin.wzl

fix bug:data inconsistency will occur after multiple rows are replaced into

上级 e3dd01b9
......@@ -202,6 +202,7 @@ int ObTableConflictRowFetcherOp::inner_get_next_row()
LOG_DEBUG("fetch conflict row iterator end");
} else {
ObNewRowIterator* dup_row_iter = dup_row_iter_arr_.at(cur_row_idx_);
clear_evaluated_flag();
if (OB_ISNULL(dup_row_iter)) {
find_next_iter = true;
} else if (OB_FAIL(dup_row_iter->get_next_row(dup_row))) {
......
......@@ -1806,6 +1806,8 @@ int ObPartitionStorage::multi_get_rows(const ObStoreCtx& store_ctx, const ObTabl
if (OB_ISNULL(access_param.op_)) {
ret = OB_INVALID_ARGUMENT;
LOG_WARN("invalid argument", K(ret), KP(access_param.op_));
} else {
access_param.op_->clear_evaluated_flag();
}
for (int64_t i = 0; OB_SUCC(ret) && i < access_param.output_exprs_->count(); i++) {
ObDatum* datum = NULL;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册