Flink SQL如何获取JSON数组长度？UDF在SQL Gateway遇类找不到问题

一、使用Flink SQL内置函数获取数组长度 #

Flink SQL提供了两个内置函数可直接获取数组长度：

• ARRAY_LENGTH(array)：返回数组的元素个数
• CARDINALITY(array)：功能与ARRAY_LENGTH一致，同时支持数组和映射类型

针对你的示例数据，查询语句可写为：

select description, ARRAY_LENGTH(someArray) as array_length from some_table;

或者：

select description, CARDINALITY(someArray) as array_length from some_table;

以上语句均可返回someArray的长度2。

二、SQL Gateway中UDF类找不到的问题排查 #

你已将UDF的jar包放入Flink安装目录的lib文件夹，但SQL Gateway仍无法找到类，可从以下方向排查解决：

• SQL Gateway启动时未加载lib目录jar：若SQL Gateway为独立进程，需确保启动脚本将lib目录下的所有jar加入classpath，或在启动命令中显式指定UDF jar的路径。
• UDF注册方式错误：在SQL Gateway中需显式注册UDF，可通过SQL语句指定jar绝对路径完成注册，示例：

CREATE FUNCTION size_of AS 'com.your.package.SizeOfUDF' USING JAR 'file:///usr/local/Cellar/apache-flink/1.16.0/libexec/lib/your-udf.jar';

• jar包打包问题：检查jar包是否正确包含UDF类，可通过jar tf your-udf.jar命令查看jar内文件结构，确认类的全限定名与注册时一致。
• 权限问题：确保SQL Gateway进程拥有读取该jar包的权限，避免因权限不足导致类加载失败。

内容的提问来源于stack exchange，提问作者hitesh