From df5e2671ee9ffc9ffd5f85a0bba3504ad890d1a3 Mon Sep 17 00:00:00 2001 From: ZenoWang Date: Mon, 29 Jul 2024 04:36:36 +0000 Subject: [PATCH] Do retry when create direct load memtable failed && Add debug log when finish direct load --- src/storage/ddl/ob_ddl_inc_clog_callback.cpp | 4 ++++ src/storage/ob_direct_load_table_guard.cpp | 2 +- 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/src/storage/ddl/ob_ddl_inc_clog_callback.cpp b/src/storage/ddl/ob_ddl_inc_clog_callback.cpp index 81fe7fe45e..8f0c34d5df 100644 --- a/src/storage/ddl/ob_ddl_inc_clog_callback.cpp +++ b/src/storage/ddl/ob_ddl_inc_clog_callback.cpp @@ -211,6 +211,10 @@ int ObDDLIncCommitClogCb::on_success() if (log_basic_.get_lob_meta_tablet_id().is_valid()) { (void)ls->tablet_freeze(log_basic_.get_lob_meta_tablet_id(), is_sync); } + FLOG_INFO("Commit Async Tablet Freeze Task by DDL Commit Log", + K(ls_id_), + K(log_basic_.get_tablet_id()), + K(log_basic_.get_lob_meta_tablet_id())); } status_.set_ret_code(ret); diff --git a/src/storage/ob_direct_load_table_guard.cpp b/src/storage/ob_direct_load_table_guard.cpp index 8fb3e2829a..40c569577b 100644 --- a/src/storage/ob_direct_load_table_guard.cpp +++ b/src/storage/ob_direct_load_table_guard.cpp @@ -135,7 +135,7 @@ int ObDirectLoadTableGuard::acquire_memtable_once_() } if (OB_FAIL(ret)) { - if ((OB_ALLOCATE_MEMORY_FAILED == ret || OB_MINOR_FREEZE_NOT_ALLOW == ret) && + if ((OB_EAGAIN == ret || OB_ALLOCATE_MEMORY_FAILED == ret || OB_MINOR_FREEZE_NOT_ALLOW == ret) && (ObClockGenerator::getClock() - start_time < MAX_RETRY_CREATE_MEMTABLE_TIME)) { ret = OB_SUCCESS; need_create_new_memtable = true;