INSERT INTO result_tableSELECT name, tagFROM source_tableCROSS JOIN UNNEST(SPLIT(tags, ',')) AS t(tag);
https://github.com/apache/flink/tree/blink
开源了,目前是 flink 的一个分支