Flink CDC有没有大佬做过mysql表的数据吧一对多的父子表同步到es中的需求呢，帮解答一下？

Flink CDC有没有大佬做过mysql表的数据吧一对多的父子表同步到es中的需求呢，我想知道flink sql是否有这样的能力，然后我就写sql去试，就发现这一条sql可以跑通，但是是固定数据
INSERT INTO es_album_info
SELECT a.id,a.name,author_id authorId,(select ROW(id,name) from author where a.author_id = id) as author,
ARRAY[ROW(1,'张三'),ROW(2,'李四')] as tags
FROM album_info a;
我按照我的想法把它改成读取表中的数据，就会报错了像这样
INSERT INTO es_album_info
SELECT a.id,a.name,author_id authorId,(select ROW(id,name) from author where a.author_id = id) as author,
ARRAY[(select ROW(id,name) from tags where a.id = album_id)] as tags
FROM album_info a;
有没有大佬帮解答一下呢？