有没有哪位在flink sql中使用 过string转json_array的函数？

试下这些函数代捷此回答整理自钉群“【③群】Apache Flink China

使用 Flink SQL 中的内置函数 from_json 和 explode 来实现将 JSON 字符串转换为数组并将其拆分成单独的行。

SELECT uuid, field1, field2
FROM (
  SELECT uuid, from_json(body_data, ARRAY<ROW<field1 INT, field2 INT>>) as data
  FROM kafka_topic
) t, LATERAL TABLE(explode(data)) as exploded_table(field1, field2)

使用 from_json 函数将 body_data 字段中的 JSON 字符串转换为数组。然后，使用 LATERAL TABLE 和 explode 函数将数组拆分成单独的行，并将每个 ROW<field1 INT, field2 INT> 的值作为单独的列返回。