filter(ticdc): Add lightning_task_info as the system table schema t…

…hat should not be replicated by TiCDC (#11359) (#11362)

close #11356

pkg/filter/filter.go

@@ -26,6 +26,8 @@ const (
 	SyncPointTable = "syncpoint_v1"
 	// TiCDCSystemSchema is the schema only use by TiCDC.
 	TiCDCSystemSchema = "tidb_cdc"
+	// LightningTaskInfoSchema is the schema only generated by Lightning
+	LightningTaskInfoSchema = "lightning_task_info"
 )
 
 // ddlWhiteListMap is a map of all DDL types that can be applied to cdc's schema storage.

pkg/filter/filter_test.go

@@ -34,6 +34,7 @@ func TestShouldUseDefaultRules(t *testing.T) {
 	require.False(t, filter.ShouldIgnoreTable("metric_schema", "query_duration"))
 	require.False(t, filter.ShouldIgnoreTable("sns", "user"))
 	require.True(t, filter.ShouldIgnoreTable("tidb_cdc", "repl_mark_a_a"))
+	require.True(t, filter.ShouldIgnoreTable("lightning_task_info", "conflict_records"))
 }
 
 func TestShouldUseCustomRules(t *testing.T) {

pkg/filter/utils.go

@@ -31,6 +31,8 @@ func isSysSchema(db string) bool {
 	// Tables in TiCDCSystemSchema should not be replicated by cdc.
 	case TiCDCSystemSchema:
 		return true
+	case LightningTaskInfoSchema:
+		return true
 	default:
 		return tifilter.IsSystemSchema(db)
 	}