无法打开要连接的客户端传输配置单元

brgchamk  于 2021-06-24  发布在  Hive
关注(0)|答案(0)|浏览(234)
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()

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题