flink
flink copied to clipboard
Published
20 hours ago •
apache
apache
[FLINK-26474][hive] Fold exprNode to fix the issue of failing to call some hive udf required constant parameters with implicit constant passed
trafficstars
What is the purpose of the change
The change is to enable ExprNode folding and to fold UDFOPNegative.
It's mainly to fix the issue that it'll throw the exception BROUND second argument only takes constant when call some hive udf requiring constant parameter with implicit constant like -1 or cast(null as int) .
Brief change log
- enable ExprNode fold
- when the ExprNodeDesc is negative operator, try to fold it to ExprNodeConstantDesc
- modify the logic for
convertConstantinHiveParserRexNodeConverterfor the value for the data type ofIntervalYearMonth/IntervalDayTimeTypewill be class ofHiveIntervalYearMonth,HiveIntervalDayTime.
Verifying this change
Added udf.q contains the sql statements that'll fail before this fix.
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: (yes / no / don't know)
- 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? no
CI report:
- 6502419767b95bb0ce6e419b4f455d6e867c272d Azure: SUCCESS
Bot commands
The @flinkbot bot supports the following commands:@flinkbot run azurere-run the last Azure build
HiveDialectQueryITCase.testCastTimeStampToDecimal:804 is failed, please take a look.
