flink
flink copied to clipboard
[FLINK-27175][hive] Fix fail to call Hive UDAF when the UDAF accepts one parameter with array type
What is the purpose of the change
To fix fail to call Hive UDAF when the UDAF accepts one parameter with array type
Brief change log
When the parameter is a single array, wrap it to an array.
Verifying this change
Added test method testUDAFCollectList
in HiveGenericUDAFTest.java
Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): no
- The public API, i.e., is any changed class annotated with
@Public(Evolving)
: no - The serializers: no
- The runtime per-record code paths (performance sensitive): no
- Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: no
- The S3 file system connector: no
Documentation
- Does this pull request introduce a new feature? no
- If yes, how is the feature documented? N/A
CI report:
- e89c5b92b231c7e7f2e606387fc1d4a2ada32e35 Azure: FAILURE
Bot commands
The @flinkbot bot supports the following commands:-
@flinkbot run azure
re-run the last Azure build
@flinkbot run azure
@hehuiyuan Thanks very much for your review.
@hehuiyuan Thanks very much for your review.
We are just doing some hive compatibility verification.
@luoyuxia Thanks for your contribution, I left a minor comment. Overall, LGTM
Could you add an IT case for this?
Could you add an IT case for this?
Sure. Now, I add a query in udaf.q to verify this fix. Without this fix, the query will fail to run.