From 764ebbcbe90dffb8bf5dec71d3a9a3e557ecfa9d Mon Sep 17 00:00:00 2001 From: obdev Date: Wed, 11 Dec 2024 08:44:55 +0000 Subject: [PATCH] fix mgr not removed. --- src/storage/ddl/ob_complement_data_task.cpp | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/storage/ddl/ob_complement_data_task.cpp b/src/storage/ddl/ob_complement_data_task.cpp index 82b48f69d7..2acb787df6 100644 --- a/src/storage/ddl/ob_complement_data_task.cpp +++ b/src/storage/ddl/ob_complement_data_task.cpp @@ -571,6 +571,12 @@ ObComplementDataDag::ObComplementDataDag() ObComplementDataDag::~ObComplementDataDag() { + ObTenantDirectLoadMgr *tenant_direct_load_mgr = MTL(ObTenantDirectLoadMgr *); + if (nullptr != tenant_direct_load_mgr) { + (void) tenant_direct_load_mgr->close_tablet_direct_load(context_.context_id_, context_.direct_load_type_, + param_.dest_ls_id_, param_.dest_tablet_id_, false/*need_commit*/, true/*emergent_finish*/, + param_.task_id_, param_.dest_table_id_, 1/*execution_id*/); + } } int ObComplementDataDag::init(const ObDDLBuildSingleReplicaRequestArg &arg)