utils: skip workload schema hack

pkg/filter/filter.go

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

pkg/filter/filter_test.go

@@ -31,6 +31,7 @@ func TestShouldUseDefaultRules(t *testing.T) {
 	require.True(t, filter.ShouldIgnoreTable("information_schema", ""))
 	require.True(t, filter.ShouldIgnoreTable("information_schema", "statistics"))
 	require.True(t, filter.ShouldIgnoreTable("performance_schema", ""))
+	require.True(t, filter.ShouldIgnoreTable(TiDBWorkloadSchema, "hist_snapshots"))
 	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"))

pkg/filter/utils.go

@@ -33,6 +33,9 @@ func isSysSchema(db string) bool {
 		return true
 	case LightningTaskInfoSchema:
 		return true
+	// TODO: skip workload schema, ref https://github.com/pingcap/tiflow/issues/12084 .
+	case TiDBWorkloadSchema:
+		return true
 	default:
 		return tifilter.IsSystemSchema(db)
 	}