Я установил Hadoop, Hive и Airflow на Ubuntu. Теперь я пытаюсь получить доступ к кусту, используя Airflow, чтобы выполнить некоторые hql. Согласно документам, я использую HiveOperator в моей DAG. я создал новый conn_id в пользовательском интерфейсе Airflow под Admin -> соединения.
conn_id = hive_conn
host = localhost
но когда я запускаю файл DAG, я получаю сообщение об ошибке ниже,
Исключение в потоке "main" java .lang.RuntimeException: База данных Hive metastore не инициализирована , Пожалуйста, используйте schematool (например, ./schematool -initSchema -dbType ...) для создания схемы. Может ли кто-нибудь помочь мне в решении этой проблемы.