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

[CP] Fix unexpected row order of restore table scan

Browse Source
This commit is contained in:
Hongqin-Li
2023-10-25 08:13:40 +00:00
committed by ob-robot
parent 6e7d0b980e
commit 971719bdd1
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/storage/ddl/ob_complement_data_task.cpp
View File

@ -2117,12 +2117,20 @@ int ObRemoteScan::generate_build_select_sql(ObSqlString &sql_string)
static_cast<int>(query_column_sql_string.length()), query_column_sql_string.ptr(), static_cast<int>(query_column_sql_string.length()), query_column_sql_string.ptr(),
static_cast<int>(query_partition_sql.length()), query_partition_sql.ptr()))) { static_cast<int>(query_partition_sql.length()), query_partition_sql.ptr()))) {
LOG_WARN("fail to assign sql string", K(ret), K(query_column_sql_string), K(query_partition_sql)); LOG_WARN("fail to assign sql string", K(ret), K(query_column_sql_string), K(query_partition_sql));
} else if (OB_FAIL(sql_string.append("order by "))) {
LOG_WARN("append failed", K(ret));
} else {
for (int64_t i = 0; OB_SUCC(ret) && i < orig_table_schema->get_rowkey_column_num(); i++) {
if (OB_FAIL(sql_string.append_fmt("%s %ld", i == 0 ? "": ",", i+1))) {
LOG_WARN("append fmt failed", K(ret));
} }
} }
} }
} }
} }
LOG_TRACE("generate query sql finished", K(ret), K(sql_string)); }
}
FLOG_INFO("generate query sql finished", K(ret), K(sql_string));
return ret; return ret;
} }