Error: Could not open client transport with JDBC Uri: jdbc:hive2://XXXX:10000/default;auth=none: Failed to open new session: java.lang.IllegalArgumentException: Cannot modify airflow.ctx.task_id at runtime. It is not in list of params that are allowed to be modified at runtime (state=08S01,code=0)
Beeline version 2.3.6 by Apache Hive
我曾尝试将hiveconfs的参数更改为none,但仍然遇到问题
我使用的配置:
airflow连接是基于基于hive zookeeper的jdbc连接配置的,并使用“hive客户端 Package 器”作为连接类型。正在尝试传递一些额外的参数来连接附加组件:{“hive\u cli\u params”:“”,“use\u beeline”:“true”,“auth”:“none”}
dag代码示例:
import airflow
from airflow import DAG
from airflow.operators.hive_operator import HiveOperator
from airflow.utils.dates import days_ago
dag_conf = DAG(dag_id = "airflow_hiveoperator",schedule_interval = None,start_date = airflow.utils.dates.days_ago(1))
HiveOperator = HiveOperator(
hql='hql/query1.hql',
task_id = 'airflow_hive',
schema='default',
hiveconf_jinja_translate=False,
dag = dag_conf,
conn_id = 'hive_cli_default',
hiveconfs=None
)
if __name__ == "__main__":
dag_conf.cli()
暂无答案!
目前还没有任何答案,快来回答吧!