非常感谢，但是我试过的 hive.xx_db.xx_udf 这种方式是找不到这个udf的，必须使用 tableEnv.useCatalog("hive")
、tableEnv.useDatabase("default")
在2019年9月26日 16:43，Terry Wang<zjuwa...@gmail.com> 写道：
问题1:
default关键词报错是否试过 hive.`default`.xx_udf 方式, 这样转义应该能解决关键词报错的问题。
问题2:
flink 1.10 中会支持modular plugin的方式，使用起来会更方便
Best,
Terry Wang
在 2019年9月25日，下午7:21，like <likeg...@163.com> 写道：
各位大佬好：
目前我在使用1.9版本中hive的udf碰到如下问题：
1、hive的udf都是注册在default库中，sql里面带有default关键词，flink程序就会报错
我通过 tableEnv.useCatalog("hive")
、tableEnv.useDatabase("default")这种方式解决了default关键词的问题
同时发现如果不使用tableEnv.useDatabase("xx_db"),直接使用 xx_db.fun是找不到函数的
2、使用上面的方式能使用hive中指定某个库的udf，但是需要使用flink中注册的表会很麻烦
sql里需要这么写（default_catalog.default_database.xx_table）
请问大家有没有好的使用方式和建议？感谢 ！
