luoyuxia commented on code in PR #19714:
URL: https://github.com/apache/flink/pull/19714#discussion_r894143499
##########
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParser.java:
##########
@@ -218,7 +217,11 @@ private List<Operation> processCmd(
// parse statement to get AST
final HiveParserASTNode node = HiveASTParseUtils.parse(cmd,
context);
Operation operation;
- if (DDL_NODES.contains(node.getType())) {
+ if (node.getType() == HiveASTParser.TOK_RELOADFUNCTION) {
+ // call reload function
+ hiveCatalog.reloadFunctions();
Review Comment:
Good catch. It's the first version for I mistake it that we need to call
reload functions. But after some investigation about the function load
mechanism in Flink, I found we don't need to reloadFunctions. It should be
removed. But I haven't removed it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
