Flink 1.10在udf中传入array<row>类型的解析异常

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

Flink 1.10在udf中传入array<row>类型的解析异常

sunfulin
hi,
我遇到一个问题,消费的source里有字段定义为array<row<f1 int, f2 string>>这种类型,然后想通过一个udf将它处理成一个字符串。udf的入参定义如下:


public String eval(Row[] item, String char1, String char2);


但是在函数处理时,debug发现拿到的item里的row信息始终为null。也通过DataTypeHint注解给出了item的实际类型。这是不是1.10的bug呀?如果有相关的issue单的话,烦请有知道的发我下哈。
我在1.11里验证同样的逻辑,是没这个问题的。