[OBCDC] Fix OBCDC stuck while handling outrow ddl_stmt

oceanbase · May 6, 2023 · bd50a54 · bd50a54
1 parent 6c66661
commit bd50a54
Showing 1 changed file with 5 additions and 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
@@ -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(),