From bd50a54ac52a82c5cd3b100781d5ed252822ccd0 Mon Sep 17 00:00:00 2001 From: SanmuWangZJU Date: Sat, 6 May 2023 14:09:29 +0000 Subject: [PATCH] [OBCDC] Fix OBCDC stuck while handling outrow ddl_stmt --- src/logservice/libobcdc/src/ob_log_part_trans_parser.cpp | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/src/logservice/libobcdc/src/ob_log_part_trans_parser.cpp b/src/logservice/libobcdc/src/ob_log_part_trans_parser.cpp index 73bf64d36..c37a4ad93 100644 --- a/src/logservice/libobcdc/src/ob_log_part_trans_parser.cpp +++ b/src/logservice/libobcdc/src/ob_log_part_trans_parser.cpp @@ -406,9 +406,12 @@ int ObLogPartTransParser::parse_mutator_row_( } else if (table_info.is_index_table()) { need_filter = true; filter_reason = "INDEX_TABLE"; - } else if (part_trans_task.is_ddl_trans() && ! is_ddl_tablet(part_trans_task.get_ls_id(), tablet_id)) { + // DDL Table and LOB_AUX TABLE for DDL Table should not ignore + } else if (part_trans_task.is_ddl_trans() + && ! (is_ddl_tablet(part_trans_task.get_ls_id(), tablet_id) + || is_all_ddl_operation_lob_aux_tablet(part_trans_task.get_ls_id(), tablet_id))) { need_filter = true; - filter_reason = "NON_DDL_TABLE_DATA"; + filter_reason = "NON_DDL_RELATED_TABLE"; } else if (OB_FAIL(part_mgr.is_exist_table_id_cache(table_info.get_table_id(), is_in_table_id_cache))) { LOG_ERROR("check is_exist_table_id_cache failed", KR(ret), "tls_id", part_trans_task.get_tls_id(), -- GitLab