[FLINK-27603] Hive dialect supports "reload function"

• Type: Sub-task
• Status: In Progress
• Priority: Major
• Resolution: Unresolved
• Fix Version/s: 1.20.0
• Component/s: Connectors / Hive
• Labels: pull-request-available stale-assigned
• Assignee: luoyuxia
• Reporter: luoyuxia
• Created: 13/May/22 10:18
• Updated: 14/Mar/24 07:36

Description

In Hive, by "reload function", the user can use the function defined in other session.

But in flink, it will always get the function from the catalog, and if it's hive catalog, it'll load all the user defined functions from the metastore.

So, there's no need to "reload function" explicitly for it actually is done implicitly.

But when use Hive dialect in Flink, it'll throw an unsupported exception for  the statement  "reload function".

I'm wondering keep the current behavior to throw excpetion or consider it as an 'NopOperation'.

 

Issue Links

• links to: GitHub Pull Request #19714