I encountered an issue while using Flink CDC to sync data from MySQL to Elasticsearch. There’s a one-to-many relationship between two MySQL tables, “matcher” and “matcher_task”.