fix the bug of direct load in mv complete refresh

2024-06-18 09:16:21 +00:00
parent bc0553b107
commit 964cb5dd52
17 changed files with 61 additions and 214 deletions
--- a/src/sql/code_generator/ob_static_engine_cg.cpp
+++ b/src/sql/code_generator/ob_static_engine_cg.cpp
@ -8090,7 +8090,7 @@ int ObStaticEngineCG::set_other_properties(const ObLogPlan &log_plan, ObPhysical
            int64_t ddl_task_id = 0;
            const ObOptParamHint *opt_params = &log_plan.get_stmt()->get_query_ctx()->get_global_hint().opt_params_;
            OZ(opt_params->get_integer_opt_param(ObOptParamHint::DDL_TASK_ID, ddl_task_id));
-            log_plan.get_optimizer_context().get_exec_ctx()->get_table_direct_insert_ctx().set_ddl_task_id(ddl_task_id);
+            phy_plan.set_ddl_task_id(ddl_task_id);
          }
        }
      }