Flink SQL读取复杂JSON格式

[破极]

Hello，各位大佬：
请教下大佬们，在Flink 
SQL中读取Kafka中的数据，但Kafka中的数据比较复杂，其中json的data属性中的值是数组，但数组的内容是动态的，没有统一，如果定义create 
table时候schema呢？我定义了array<string>，想自己定义UDF来处理的，在JsonNode中的asText无法取到数据。
请问各位大佬有啥高招呢？谢谢。


kafka消息样例(data的value是动态的)：
{"source":"transaction_2020202020200","data":[{"name":"d1111"},{"age":18}]}
我定义的schema：
create table kafka_message(
 source string,
data array<string>
)with...