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 73bf64d36c31f37efb354acb946d9fceef4b13c4..c37a4ad93757e2b5446bc97cbd3365e12c43405d 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(),