Flink CDC里flink sql 有啥内置函数 可以将 51,51 变成 [51,52] 吗？

问题一：Flink CDC中没有内置函数可以将51,51变成[51,52]。split也不是内置函数。

问题二：Flink CDC中没有内置函数可以直接进行数组去重或数组对比。但是，你可以使用其他方法来实现这些功能。

对于数组去重，你可以使用DISTINCT关键字来对数组元素进行去重。例如：

SELECT DISTINCT column_name FROM table_name;

对于数组对比，你可以使用UNNEST函数将数组拆分为多行，然后使用JOIN操作进行对比。例如：

SELECT a.value
FROM (SELECT UNNEST(array1) AS value FROM table_name) AS a
LEFT JOIN (SELECT UNNEST(array2) AS value FROM table_name) AS b
ON a.value = b.value
WHERE b.value IS NULL;

这个查询将返回在array1中存在但在array2中不存在的元素。

LISTAGG。此回答来自钉群Flink CDC 社区。

对于您的两个问题：
a) 转换51,51到[51,52]：没有直接的内置函数来实现这样的转换，但你可以使用字符串函数结合数组函数实现，例如先split然后用array函数构造数组。
b) 数组去重或对比：对于数组去重，Flink SQL有DISTINCT关键字可以在数组元素上使用，不过这需要借助UNNEST配合子查询来实现；对于数组对比并返回交集，没有直接的内置函数，但是可以通过一系列的 unnest、join 和 collect_set/array_agg 等操作来完成。