hcq/oceanbase
hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

[CP] [OBCDC] Fix OBCDC stuck while handling outrow ddl_stmt

Browse Source
This commit is contained in:
SanmuWangZJU 2023-05-08 12:12:09 +00:00 committed by ob-robot
parent 994138989a
commit c3345fcb02
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/logservice/libobcdc/src/ob_log_part_trans_parser.cpp
View File

@ -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(),