用例是运行配置单元中的sql列表并更新impala元数据。如下所示,hive和impala的两个方法使用jdbc_hook。按照我调用这些方法的顺序,只有第一个方法运行,第二个方法抛出错误- java.lang.RuntimeException: Class <driver name of hive/impala> not found。当单独使用时,每种方法都运行良好。请找到airflow自定义运算符的execute方法:注意::我不能使用hive_operator运行hive语句。我在HiveServer2_Hook中看不到任何方法。我是第一次接触airflow,非常感谢您的帮助
我可以在hive和impala中使用基于java的UDF,但在where子句中调用udf时抛出ClassNotFound错误。 当在where子句中引用时,自定义函数不能使用,但当它仅在impala 2.9.0-cdh5.12.1中的select后面引用时,它才能正常工作 在hive中,select udfjson(memo,state) from tableA where udfjson(memo,state) = 0 and name = 'test'工作正常,但在impala中无法正常工作。 在impala中执行select udfjson(memo,state) fr
我不知道下面的蜂巢查询有什么问题。然而,这是抛出的错误。
select h.database_name, h.table_name, h.frequency as hive_frequency, i.frequency as impala_frequency
from hive_access_frequency h
left join impala_access_frequency i
on
h.database_name = i.database_name and
h.table_name = i.table_name
union
select i.database_name,
在我的hive脚本的开头,我有这样一条语句:
create function x as y using jar z;
现在,如果函数已经存在,它会给我一个错误:
Error while processing statement: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.FunctionTask. AlreadyExistsException(message:Function x already exists)
如果我使用create function if not exists x a