hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] Fix the issue of incorrect results in flashback query

Browse Source
This commit is contained in:
leslieyuchen
2023-11-06 07:39:42 +00:00
committed by ob-robot
parent c1fb7fe9f8
commit 0c8e9d598d
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/sql/engine/table/ob_table_scan_op.cpp
View File

@ -923,10 +923,12 @@ OB_INLINE int ObTableScanOp::init_das_scan_rtdef(const ObDASScanCtDef &das_ctdef
int64_t schema_version = task_exec_ctx.get_query_tenant_begin_schema_version(); int64_t schema_version = task_exec_ctx.get_query_tenant_begin_schema_version();
das_rtdef.tenant_schema_version_ = schema_version; das_rtdef.tenant_schema_version_ = schema_version;
} }
if (OB_SUCC(ret) && MY_SPEC.ref_table_id_ == das_ctdef.ref_table_id_) { if (OB_SUCC(ret)) {
//only data table scan need to set flashback query info
if (OB_FAIL(tsc_ctdef.flashback_item_.set_flashback_query_info(eval_ctx_, das_rtdef))) { if (OB_FAIL(tsc_ctdef.flashback_item_.set_flashback_query_info(eval_ctx_, das_rtdef))) {
LOG_WARN("failed to set flashback query snapshot version", K(ret)); LOG_WARN("failed to set flashback query snapshot version", K(ret));
} else if (MY_SPEC.ref_table_id_ != das_ctdef.ref_table_id_) {
//only data table scan need to set row scn flag
das_rtdef.need_scn_ = false;
} }
} }
if (OB_SUCC(ret)) { if (OB_SUCC(ret)) {