From 94faa4ef4230402e23f9f15105c37874c0f74ba9 Mon Sep 17 00:00:00 2001 From: Monk-Liu <1152761042@qq.com> Date: Wed, 19 Jul 2023 06:48:33 +0000 Subject: [PATCH] [bugfix]: fix schema_version_hint bug. --- src/share/ob_ddl_common.cpp | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/src/share/ob_ddl_common.cpp b/src/share/ob_ddl_common.cpp index 681686fb60..8db1dd680d 100644 --- a/src/share/ob_ddl_common.cpp +++ b/src/share/ob_ddl_common.cpp @@ -725,7 +725,6 @@ int ObDDLUtil::generate_build_replica_sql( ObString new_dest_table_name; ObString new_source_table_name; ObString new_source_database_name; - ObString new_table_schema_version_hint; if (OB_FAIL(sql::ObSQLUtils::generate_new_name_with_escape_character( allocator, @@ -760,7 +759,6 @@ int ObDDLUtil::generate_build_replica_sql( LOG_WARN("failed to generated ddl schema hint", K(ret)); } } - if (OB_FAIL(ret)) { } else if (oracle_mode) { if (OB_FAIL(sql_string.assign_fmt("INSERT /*+ monitor enable_parallel_dml parallel(%ld) opt_param('ddl_execution_id', %ld) opt_param('ddl_task_id', %ld) opt_param('enable_newsort', 'false') use_px */INTO \"%.*s\".\"%.*s\"(%.*s) SELECT /*+ index(\"%.*s\" primary) %.*s */ %.*s from \"%.*s\".\"%.*s\" as of scn %ld %.*s", @@ -768,7 +766,7 @@ int ObDDLUtil::generate_build_replica_sql( static_cast(new_dest_database_name.length()), new_dest_database_name.ptr(), static_cast(new_dest_table_name.length()), new_dest_table_name.ptr(), static_cast(insert_column_sql_string.length()), insert_column_sql_string.ptr(), static_cast(new_source_table_name.length()), new_source_table_name.ptr(), - static_cast(new_table_schema_version_hint.length()), new_table_schema_version_hint.ptr(), + static_cast(src_table_schema_version_hint_sql_string.length()), src_table_schema_version_hint_sql_string.ptr(), static_cast(query_column_sql_string.length()), query_column_sql_string.ptr(), static_cast(new_source_database_name.length()), new_source_database_name.ptr(), static_cast(new_source_table_name.length()), new_source_table_name.ptr(), snapshot_version, static_cast(rowkey_column_sql_string.length()), rowkey_column_sql_string.ptr()))) { @@ -780,7 +778,7 @@ int ObDDLUtil::generate_build_replica_sql( static_cast(new_dest_database_name.length()), new_dest_database_name.ptr(), static_cast(new_dest_table_name.length()), new_dest_table_name.ptr(), static_cast(insert_column_sql_string.length()), insert_column_sql_string.ptr(), static_cast(new_source_table_name.length()), new_source_table_name.ptr(), - static_cast(new_table_schema_version_hint.length()), new_table_schema_version_hint.ptr(), + static_cast(src_table_schema_version_hint_sql_string.length()), src_table_schema_version_hint_sql_string.ptr(), static_cast(query_column_sql_string.length()), query_column_sql_string.ptr(), static_cast(new_source_database_name.length()), new_source_database_name.ptr(), static_cast(new_source_table_name.length()), new_source_table_name.ptr(), snapshot_version, static_cast(rowkey_column_sql_string.length()), rowkey_column_sql_string.ptr()))) {