[FLINK-33596] Support fold expression before transfer to RexNode

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Component/s: Connectors / Hive
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: yunfan
• Created: 20/Nov/23 09:59
• Updated: 16/Jan/24 13:47

Description

Hive will fold expression in optimization stage. But flink-hive-parser use flink optimization.

And flink can't know some hive function can be constant value.

It can be reproduce by follow sql

select distinct(dep), UNIX_TIMESTAMP()  from employee 

Some hive code reference:

https://github.com/apache/hive/blob/rel/release-2.3.9/ql/src/java/org/apache/hadoop/hive/ql/optimizer/calcite/HiveRexExecutorImpl.java#L62

https://github.com/apache/hive/blob/rel/release-2.3.9/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java#L1776

https://github.com/apache/hive/blob/rel/release-2.3.9/ql/src/java/org/apache/hadoop/hive/ql/parse/CalcitePlanner.java#L1069

Issue Links

• links to: GitHub Pull Request #15
• links to: GitHub Pull Request #23759