DTStack / DTStack/chunjun

chunjun UDF接收参数问题:无法接收复杂数据结构

Open
#1,414 0 comments 0 reactions 0 assignees View on GitHub
bug
Dominant language
Java
Stars
4.1k
Forks
1.7k
PR merge metrics
No merged PRs in 30d

Description

### Search before asking

- [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues.

### What happened

1、源端SQL
![1669684525(1)](https://user-images.githubusercontent.com/34857750/204414385-9a11043a-99ca-49a9-b893-2294d549145a.png)
2、需要通过UDF接收的参数格式为:
d array< row >

3、UDF参数如下:
![1669684623(1)](https://user-images.githubusercontent.com/34857750/204414585-864ba82e-7581-4155-b9c7-2f96cac75b2f.png)
4、UDF无法接收这种参数,chunjun会报:参数类型不匹配,要求是:List> 实际是这种: array< row >但是在原生的flink里面 是没有问题

### What you expected to happen

1、源端SQL
![1669684525(1)](https://user-images.githubusercontent.com/34857750/204414385-9a11043a-99ca-49a9-b893-2294d549145a.png)
2、需要通过UDF接收的参数格式为:
d array< row >

3、UDF参数如下:
![1669684623(1)](https://user-images.githubusercontent.com/34857750/204414585-864ba82e-7581-4155-b9c7-2f96cac75b2f.png)
4、UDF无法接收这种参数,chunjun会报:参数类型不匹配,要求是:List> 实际是这种: array< row >但是在原生的flink里面 是没有问题

### How to reproduce

1、源端SQL
![1669684525(1)](https://user-images.githubusercontent.com/34857750/204414385-9a11043a-99ca-49a9-b893-2294d549145a.png)
2、需要通过UDF接收的参数格式为:
d array< row >

3、UDF参数如下:
![1669684623(1)](https://user-images.githubusercontent.com/34857750/204414585-864ba82e-7581-4155-b9c7-2f96cac75b2f.png)
4、UDF无法接收这种参数,chunjun会报:参数类型不匹配,要求是:List> 实际是这种: array< row >但是在原生的flink里面 是没有问题

### Anything else

_No response_

### Version

1.12_release

### Are you willing to submit PR?

- [X] Yes I am willing to submit a PR!

### Code of Conduct

- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.