airflow initdb出错

Question

好不容易安装上，airflow initdb又出错了。

ERROR [airflow.models.DagBag] Failed to import:
/usr/local/lib/python2.7/dist-packages/airflow/example_dags/example_twitter_dag.py
Traceback (most recent call last): File
"/usr/local/lib/python2.7/dist-packages/airflow/models.py", line 247,
in process_file

m = imp.load_source(mod_name, filepath)   File "/usr/local/lib/python2.7/dist-packages/airflow/example_dags/example_twitter_dag.py",

line 26, in <module>

from airflow.operators import BashOperator, HiveOperator, PythonOperator ImportError: cannot import name HiveOperator

Answer 1

运行如下命令安装airflow hive模块

pip install airflow[hive]