Airflow HiveOperator 无法正常工作

Question

我试着在气流中使用蜂箱操纵器。我已经安装了所有的依赖项（pyhs2、pyhive和runpip install flow[hive]）。在

但是当我使用下面的代码时

t1 = HiveOperator(
    task_id='simple_query',
    hql='select * from cities',
    dag=dag)

我得到这个错误。我不知道这是什么意思

^{pr2}$

Answer 1

当hive命令行界面（CLI）在系统路径中不可用时，会发生此错误。在