From 05d645d1eb613dc5c3551303ca1d3b231ad83e7d Mon Sep 17 00:00:00 2001 From: Elad Kalif Date: Tue, 28 Jun 2022 23:24:43 +0300 Subject: [PATCH] Fixing `auth_mechanism` in `HiveMetastoreHook`/`HiveServer2Hook` Fix to the code applied in https://github.com/apache/airflow/pull/24713 for previous provider version we need to fix the docs to `authMechanism` --- .../providers/apache/hive/hooks/hive.html | 116 ++++++++--------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../connections/hive_metastore.rst.txt | 4 +- .../_sources/connections/hiveserver2.rst.txt | 4 +- .../2.0.0/connections/hive_metastore.html | 108 ++++++++-------- .../2.0.0/connections/hiveserver2.html | 108 ++++++++-------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../connections/hive_metastore.rst.txt | 4 +- .../_sources/connections/hiveserver2.rst.txt | 4 +- .../2.0.1/connections/hive_metastore.html | 108 ++++++++-------- .../2.0.1/connections/hiveserver2.html | 108 ++++++++-------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../connections/hive_metastore.rst.txt | 4 +- .../_sources/connections/hiveserver2.rst.txt | 4 +- .../2.0.2/connections/hive_metastore.html | 108 ++++++++-------- .../2.0.2/connections/hiveserver2.html | 108 ++++++++-------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../connections/hive_metastore.rst.txt | 4 +- .../_sources/connections/hiveserver2.rst.txt | 4 +- .../2.0.3/connections/hive_metastore.html | 108 ++++++++-------- .../2.0.3/connections/hiveserver2.html | 108 ++++++++-------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../connections/hive_metastore.rst.txt | 4 +- .../_sources/connections/hiveserver2.rst.txt | 4 +- .../2.1.0/connections/hive_metastore.html | 108 ++++++++-------- .../2.1.0/connections/hiveserver2.html | 108 ++++++++-------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../connections/hive_metastore.rst.txt | 4 +- .../_sources/connections/hiveserver2.rst.txt | 4 +- .../2.2.0/connections/hive_metastore.html | 108 ++++++++-------- .../2.2.0/connections/hiveserver2.html | 108 ++++++++-------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../connections/hive_metastore.rst.txt | 4 +- .../_sources/connections/hiveserver2.rst.txt | 4 +- .../2.3.0/connections/hive_metastore.html | 108 ++++++++-------- .../2.3.0/connections/hiveserver2.html | 108 ++++++++-------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../connections/hive_metastore.rst.txt | 4 +- .../_sources/connections/hiveserver2.rst.txt | 4 +- .../2.3.1/connections/hive_metastore.html | 108 ++++++++-------- .../2.3.1/connections/hiveserver2.html | 108 ++++++++-------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../connections/hive_metastore.rst.txt | 4 +- .../_sources/connections/hiveserver2.rst.txt | 4 +- .../2.3.2/connections/hive_metastore.html | 108 ++++++++-------- .../2.3.2/connections/hiveserver2.html | 108 ++++++++-------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../connections/hive_metastore.rst.txt | 4 +- .../_sources/connections/hiveserver2.rst.txt | 4 +- .../2.3.3/connections/hive_metastore.html | 108 ++++++++-------- .../2.3.3/connections/hiveserver2.html | 108 ++++++++-------- .../providers/apache/hive/hooks/hive.html | 118 +++++++++--------- .../connections/hive_metastore.rst.txt | 4 +- .../_sources/connections/hiveserver2.rst.txt | 4 +- .../3.0.0/connections/hive_metastore.html | 108 ++++++++-------- .../3.0.0/connections/hiveserver2.html | 108 ++++++++-------- 59 files changed, 2116 insertions(+), 2116 deletions(-) diff --git a/docs-archive/apache-airflow-providers-apache-hive/1.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/1.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html index 2a3d2ca8994..4e94b67cb3e 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/1.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/1.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -32,9 +32,9 @@ - + - +
@@ -74,38 +74,38 @@ @@ -149,38 +149,38 @@ @@ -191,8 +191,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -544,22 +544,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1070,15 +1070,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not conn: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(conn.host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1392,29 +1392,29 @@

Source code for airflow.providers.apache.hive.hooks.hive

# pylint: disable=no-member db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' from pyhive.hive import connect return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=db.password, @@ -1679,23 +1679,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1706,7 +1706,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1781,7 +1781,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1791,7 +1791,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1814,7 +1814,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1836,4 +1836,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/1.0.1/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/1.0.1/_modules/airflow/providers/apache/hive/hooks/hive.html index 4d600fc7f57..c589eeeea80 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/1.0.1/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/1.0.1/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -32,9 +32,9 @@ - + - +
@@ -74,38 +74,38 @@ @@ -149,38 +149,38 @@
@@ -191,8 +191,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -554,22 +554,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1076,15 +1076,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not conn: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(conn.host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1399,25 +1399,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

# pylint: disable=no-member db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1425,7 +1425,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1690,23 +1690,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1717,7 +1717,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1792,7 +1792,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1802,7 +1802,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1825,7 +1825,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1846,4 +1846,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/1.0.2/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/1.0.2/_modules/airflow/providers/apache/hive/hooks/hive.html index 4d600fc7f57..c589eeeea80 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/1.0.2/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/1.0.2/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -32,9 +32,9 @@ - + - +
@@ -74,38 +74,38 @@ @@ -149,38 +149,38 @@
@@ -191,8 +191,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -554,22 +554,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1076,15 +1076,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not conn: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(conn.host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1399,25 +1399,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

# pylint: disable=no-member db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1425,7 +1425,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1690,23 +1690,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1717,7 +1717,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1792,7 +1792,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1802,7 +1802,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1825,7 +1825,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1846,4 +1846,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/1.0.3/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/1.0.3/_modules/airflow/providers/apache/hive/hooks/hive.html index 96fb952c95a..2dbebb19e12 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/1.0.3/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/1.0.3/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -32,9 +32,9 @@ - + - +
@@ -74,38 +74,38 @@ @@ -149,38 +149,38 @@
@@ -191,8 +191,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -554,22 +554,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1076,15 +1076,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not conn: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(conn.host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1399,25 +1399,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

# pylint: disable=no-member db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1425,7 +1425,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1690,23 +1690,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1717,7 +1717,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1792,7 +1792,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1802,7 +1802,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1825,7 +1825,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1846,4 +1846,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html index ec2f6b1e9fb..1c92e51030b 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -32,9 +32,9 @@ - + - +
@@ -74,38 +74,38 @@ @@ -149,38 +149,38 @@
@@ -191,8 +191,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -562,22 +562,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1093,15 +1093,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not conn: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(conn.host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1422,25 +1422,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

# pylint: disable=no-member db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1448,7 +1448,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1713,23 +1713,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1740,7 +1740,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1815,7 +1815,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1825,7 +1825,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1848,7 +1848,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1869,4 +1869,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_sources/connections/hive_metastore.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_sources/connections/hive_metastore.rst.txt index b0445521acb..e85fb5ded23 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_sources/connections/hive_metastore.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_sources/connections/hive_metastore.rst.txt @@ -51,7 +51,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Metastore connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the mechanism for authentication the default is ``NOSASL``. * ``kerberos_service_name`` Specify The kerberos service name the default is ``hive``. @@ -66,4 +66,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?auth_mechanism=NOSASL' + export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?authMechanism=NOSASL' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_sources/connections/hiveserver2.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_sources/connections/hiveserver2.rst.txt index c5ae2bfa637..ba89dd58a70 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_sources/connections/hiveserver2.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.0/_sources/connections/hiveserver2.rst.txt @@ -58,7 +58,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Server2 connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the authentication method for PyHive choose between ``PLAIN``, ``LDAP``, ``KERBEROS`` or, ``Custom`` the default is ``PLAIN``. * ``kerberos_service_name`` If authenticating with kerberos specify the kerberos service name the default is ``hive``. @@ -75,4 +75,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP' + export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?authMechanism=LDAP' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.0/connections/hive_metastore.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.0/connections/hive_metastore.html index cec56ff49e2..dc6833824d9 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.0/connections/hive_metastore.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.0/connections/hive_metastore.html @@ -34,9 +34,9 @@ - + - +
@@ -76,38 +76,38 @@ @@ -151,38 +151,38 @@
@@ -193,8 +193,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -564,22 +564,22 @@ - +
- + @@ -867,4 +867,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.0/connections/hiveserver2.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.0/connections/hiveserver2.html index 7397d0e44d1..930b9cbde34 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.0/connections/hiveserver2.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.0/connections/hiveserver2.html @@ -34,9 +34,9 @@ - + - +
@@ -76,38 +76,38 @@ @@ -151,38 +151,38 @@

@@ -193,8 +193,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -564,22 +564,22 @@ - +
- +
@@ -877,4 +877,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_modules/airflow/providers/apache/hive/hooks/hive.html index e0c2d39e365..ef2801d69a8 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -32,9 +32,9 @@ - + - +

@@ -190,8 +190,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -561,22 +561,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1092,15 +1092,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not conn: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(conn.host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1421,25 +1421,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1447,7 +1447,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1710,23 +1710,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1737,7 +1737,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1812,7 +1812,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1822,7 +1822,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1845,7 +1845,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1866,4 +1866,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_sources/connections/hive_metastore.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_sources/connections/hive_metastore.rst.txt index b0445521acb..e85fb5ded23 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_sources/connections/hive_metastore.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_sources/connections/hive_metastore.rst.txt @@ -51,7 +51,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Metastore connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the mechanism for authentication the default is ``NOSASL``. * ``kerberos_service_name`` Specify The kerberos service name the default is ``hive``. @@ -66,4 +66,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?auth_mechanism=NOSASL' + export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?authMechanism=NOSASL' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_sources/connections/hiveserver2.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_sources/connections/hiveserver2.rst.txt index c5ae2bfa637..ba89dd58a70 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_sources/connections/hiveserver2.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.1/_sources/connections/hiveserver2.rst.txt @@ -58,7 +58,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Server2 connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the authentication method for PyHive choose between ``PLAIN``, ``LDAP``, ``KERBEROS`` or, ``Custom`` the default is ``PLAIN``. * ``kerberos_service_name`` If authenticating with kerberos specify the kerberos service name the default is ``hive``. @@ -75,4 +75,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP' + export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?authMechanism=LDAP' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.1/connections/hive_metastore.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.1/connections/hive_metastore.html index f7c92e63499..7d7d69ffe1b 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.1/connections/hive_metastore.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.1/connections/hive_metastore.html @@ -34,9 +34,9 @@ - + - +
@@ -192,8 +192,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -563,22 +563,22 @@ - +
- + @@ -866,4 +866,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.1/connections/hiveserver2.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.1/connections/hiveserver2.html index ffaeb9b73e5..d0ca684626d 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.1/connections/hiveserver2.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.1/connections/hiveserver2.html @@ -34,9 +34,9 @@ - + - +

@@ -192,8 +192,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -563,22 +563,22 @@ - +
- +
@@ -876,4 +876,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_modules/airflow/providers/apache/hive/hooks/hive.html index 34ae85e15b4..ede1b2dd758 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -32,9 +32,9 @@ - + - +

@@ -190,8 +190,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -563,22 +563,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1094,15 +1094,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not conn: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(conn.host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1423,25 +1423,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1449,7 +1449,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1711,23 +1711,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1738,7 +1738,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1813,7 +1813,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1823,7 +1823,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1846,7 +1846,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1867,4 +1867,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_sources/connections/hive_metastore.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_sources/connections/hive_metastore.rst.txt index b0445521acb..e85fb5ded23 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_sources/connections/hive_metastore.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_sources/connections/hive_metastore.rst.txt @@ -51,7 +51,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Metastore connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the mechanism for authentication the default is ``NOSASL``. * ``kerberos_service_name`` Specify The kerberos service name the default is ``hive``. @@ -66,4 +66,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?auth_mechanism=NOSASL' + export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?authMechanism=NOSASL' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_sources/connections/hiveserver2.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_sources/connections/hiveserver2.rst.txt index c5ae2bfa637..ba89dd58a70 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_sources/connections/hiveserver2.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.2/_sources/connections/hiveserver2.rst.txt @@ -58,7 +58,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Server2 connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the authentication method for PyHive choose between ``PLAIN``, ``LDAP``, ``KERBEROS`` or, ``Custom`` the default is ``PLAIN``. * ``kerberos_service_name`` If authenticating with kerberos specify the kerberos service name the default is ``hive``. @@ -75,4 +75,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP' + export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?authMechanism=LDAP' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.2/connections/hive_metastore.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.2/connections/hive_metastore.html index 00c429c9e2b..7b476011d90 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.2/connections/hive_metastore.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.2/connections/hive_metastore.html @@ -34,9 +34,9 @@ - + - +
@@ -192,8 +192,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -565,22 +565,22 @@ - +
- + @@ -868,4 +868,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.2/connections/hiveserver2.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.2/connections/hiveserver2.html index fae51cbd87a..08f8faf64b7 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.2/connections/hiveserver2.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.2/connections/hiveserver2.html @@ -34,9 +34,9 @@ - + - +

@@ -192,8 +192,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -565,22 +565,22 @@ - +
- +
@@ -878,4 +878,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_modules/airflow/providers/apache/hive/hooks/hive.html index d6ea5df22f3..ad9c7de8066 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -32,9 +32,9 @@ - + - +

@@ -190,8 +190,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -563,22 +563,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1093,15 +1093,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not conn: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(conn.host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1419,25 +1419,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1445,7 +1445,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1705,23 +1705,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1732,7 +1732,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1807,7 +1807,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1817,7 +1817,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1840,7 +1840,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1861,4 +1861,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_sources/connections/hive_metastore.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_sources/connections/hive_metastore.rst.txt index b0445521acb..e85fb5ded23 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_sources/connections/hive_metastore.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_sources/connections/hive_metastore.rst.txt @@ -51,7 +51,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Metastore connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the mechanism for authentication the default is ``NOSASL``. * ``kerberos_service_name`` Specify The kerberos service name the default is ``hive``. @@ -66,4 +66,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?auth_mechanism=NOSASL' + export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?authMechanism=NOSASL' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_sources/connections/hiveserver2.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_sources/connections/hiveserver2.rst.txt index c5ae2bfa637..ba89dd58a70 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_sources/connections/hiveserver2.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.3/_sources/connections/hiveserver2.rst.txt @@ -58,7 +58,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Server2 connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the authentication method for PyHive choose between ``PLAIN``, ``LDAP``, ``KERBEROS`` or, ``Custom`` the default is ``PLAIN``. * ``kerberos_service_name`` If authenticating with kerberos specify the kerberos service name the default is ``hive``. @@ -75,4 +75,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP' + export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?authMechanism=LDAP' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.3/connections/hive_metastore.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.3/connections/hive_metastore.html index 451e1f269e8..0d6fe661ffc 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.3/connections/hive_metastore.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.3/connections/hive_metastore.html @@ -34,9 +34,9 @@ - + - +
@@ -192,8 +192,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -565,22 +565,22 @@ - +
- + @@ -868,4 +868,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.0.3/connections/hiveserver2.html b/docs-archive/apache-airflow-providers-apache-hive/2.0.3/connections/hiveserver2.html index 55a14be5224..a4ae1169007 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.0.3/connections/hiveserver2.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.0.3/connections/hiveserver2.html @@ -34,9 +34,9 @@ - + - +

@@ -192,8 +192,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -565,22 +565,22 @@ - +
- +
@@ -878,4 +878,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_modules/airflow/providers/apache/hive/hooks/hive.html index 95769fd33c2..d7f5998490a 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -35,9 +35,9 @@ - + - +

@@ -193,8 +193,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -566,22 +566,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1102,15 +1102,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not host: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1430,25 +1430,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1456,7 +1456,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1716,23 +1716,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1743,7 +1743,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1818,7 +1818,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1828,7 +1828,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1851,7 +1851,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1873,4 +1873,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_sources/connections/hive_metastore.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_sources/connections/hive_metastore.rst.txt index 45316d4651c..d427398b088 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_sources/connections/hive_metastore.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_sources/connections/hive_metastore.rst.txt @@ -51,7 +51,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Metastore connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the mechanism for authentication. Default is ``NOSASL``. * ``kerberos_service_name`` Specify the kerberos service name. Default is ``hive``. @@ -66,4 +66,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?auth_mechanism=NOSASL' + export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?authMechanism=NOSASL' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_sources/connections/hiveserver2.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_sources/connections/hiveserver2.rst.txt index 1d16177d97e..bd3bc7a0a58 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_sources/connections/hiveserver2.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.1.0/_sources/connections/hiveserver2.rst.txt @@ -58,7 +58,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Server2 connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the authentication method for PyHive. Choose between ``PLAIN``, ``LDAP``, ``KERBEROS`` or ``Custom``. Default is ``PLAIN``. * ``kerberos_service_name`` If authenticating with Kerberos specify the Kerberos service name. Default is ``hive``. @@ -75,4 +75,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP' + export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?authMechanism=LDAP' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.1.0/connections/hive_metastore.html b/docs-archive/apache-airflow-providers-apache-hive/2.1.0/connections/hive_metastore.html index 3fdaee32e3a..09be67e1bce 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.1.0/connections/hive_metastore.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.1.0/connections/hive_metastore.html @@ -37,9 +37,9 @@ - + - +
@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -568,22 +568,22 @@ - +
- + @@ -872,4 +872,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.1.0/connections/hiveserver2.html b/docs-archive/apache-airflow-providers-apache-hive/2.1.0/connections/hiveserver2.html index 7d7b6cd7799..191e7b77adf 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.1.0/connections/hiveserver2.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.1.0/connections/hiveserver2.html @@ -37,9 +37,9 @@ - + - +

@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -568,22 +568,22 @@ - +
- +
@@ -882,4 +882,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_modules/airflow/providers/apache/hive/hooks/hive.html index 01a3d4423f3..c4620526cd1 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -35,9 +35,9 @@ - + - +

@@ -193,8 +193,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -566,22 +566,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1077,15 +1077,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not host: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1386,25 +1386,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1412,7 +1412,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1653,23 +1653,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1680,7 +1680,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1755,7 +1755,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1765,7 +1765,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1788,7 +1788,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1810,4 +1810,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_sources/connections/hive_metastore.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_sources/connections/hive_metastore.rst.txt index 45316d4651c..d427398b088 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_sources/connections/hive_metastore.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_sources/connections/hive_metastore.rst.txt @@ -51,7 +51,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Metastore connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the mechanism for authentication. Default is ``NOSASL``. * ``kerberos_service_name`` Specify the kerberos service name. Default is ``hive``. @@ -66,4 +66,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?auth_mechanism=NOSASL' + export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?authMechanism=NOSASL' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_sources/connections/hiveserver2.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_sources/connections/hiveserver2.rst.txt index 1d16177d97e..bd3bc7a0a58 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_sources/connections/hiveserver2.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.2.0/_sources/connections/hiveserver2.rst.txt @@ -58,7 +58,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Server2 connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the authentication method for PyHive. Choose between ``PLAIN``, ``LDAP``, ``KERBEROS`` or ``Custom``. Default is ``PLAIN``. * ``kerberos_service_name`` If authenticating with Kerberos specify the Kerberos service name. Default is ``hive``. @@ -75,4 +75,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP' + export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?authMechanism=LDAP' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.2.0/connections/hive_metastore.html b/docs-archive/apache-airflow-providers-apache-hive/2.2.0/connections/hive_metastore.html index 2c7a6487527..557411e237c 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.2.0/connections/hive_metastore.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.2.0/connections/hive_metastore.html @@ -37,9 +37,9 @@ - + - +
@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -568,22 +568,22 @@ - +
- + @@ -872,4 +872,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.2.0/connections/hiveserver2.html b/docs-archive/apache-airflow-providers-apache-hive/2.2.0/connections/hiveserver2.html index 749a7bddb6f..f1265660e03 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.2.0/connections/hiveserver2.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.2.0/connections/hiveserver2.html @@ -37,9 +37,9 @@ - + - +

@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -568,22 +568,22 @@ - +
- +
@@ -882,4 +882,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_modules/airflow/providers/apache/hive/hooks/hive.html index a8c8403df38..d51f93ead8a 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -35,9 +35,9 @@ - + - +

@@ -193,8 +193,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -568,22 +568,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1079,15 +1079,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not host: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1390,25 +1390,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1416,7 +1416,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1657,23 +1657,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1684,7 +1684,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1759,7 +1759,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1769,7 +1769,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1792,7 +1792,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1814,4 +1814,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_sources/connections/hive_metastore.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_sources/connections/hive_metastore.rst.txt index 45316d4651c..d427398b088 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_sources/connections/hive_metastore.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_sources/connections/hive_metastore.rst.txt @@ -51,7 +51,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Metastore connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the mechanism for authentication. Default is ``NOSASL``. * ``kerberos_service_name`` Specify the kerberos service name. Default is ``hive``. @@ -66,4 +66,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?auth_mechanism=NOSASL' + export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?authMechanism=NOSASL' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_sources/connections/hiveserver2.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_sources/connections/hiveserver2.rst.txt index 1d16177d97e..bd3bc7a0a58 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_sources/connections/hiveserver2.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.0/_sources/connections/hiveserver2.rst.txt @@ -58,7 +58,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Server2 connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the authentication method for PyHive. Choose between ``PLAIN``, ``LDAP``, ``KERBEROS`` or ``Custom``. Default is ``PLAIN``. * ``kerberos_service_name`` If authenticating with Kerberos specify the Kerberos service name. Default is ``hive``. @@ -75,4 +75,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP' + export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?authMechanism=LDAP' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.0/connections/hive_metastore.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.0/connections/hive_metastore.html index 7a3a69efddc..8d8649dce5e 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.0/connections/hive_metastore.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.0/connections/hive_metastore.html @@ -37,9 +37,9 @@ - + - +
@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -570,22 +570,22 @@ - +
- + @@ -874,4 +874,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.0/connections/hiveserver2.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.0/connections/hiveserver2.html index 0ac19b7a350..0397edddab9 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.0/connections/hiveserver2.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.0/connections/hiveserver2.html @@ -37,9 +37,9 @@ - + - +

@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -570,22 +570,22 @@ - +
- +
@@ -884,4 +884,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_modules/airflow/providers/apache/hive/hooks/hive.html index c05d84b8514..d020e55512b 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -35,9 +35,9 @@ - + - +

@@ -193,8 +193,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -568,22 +568,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1079,15 +1079,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not host: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1390,25 +1390,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1416,7 +1416,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1657,23 +1657,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1684,7 +1684,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1759,7 +1759,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1769,7 +1769,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1792,7 +1792,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1814,4 +1814,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_sources/connections/hive_metastore.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_sources/connections/hive_metastore.rst.txt index 45316d4651c..d427398b088 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_sources/connections/hive_metastore.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_sources/connections/hive_metastore.rst.txt @@ -51,7 +51,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Metastore connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the mechanism for authentication. Default is ``NOSASL``. * ``kerberos_service_name`` Specify the kerberos service name. Default is ``hive``. @@ -66,4 +66,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?auth_mechanism=NOSASL' + export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?authMechanism=NOSASL' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_sources/connections/hiveserver2.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_sources/connections/hiveserver2.rst.txt index 1d16177d97e..bd3bc7a0a58 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_sources/connections/hiveserver2.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.1/_sources/connections/hiveserver2.rst.txt @@ -58,7 +58,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Server2 connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the authentication method for PyHive. Choose between ``PLAIN``, ``LDAP``, ``KERBEROS`` or ``Custom``. Default is ``PLAIN``. * ``kerberos_service_name`` If authenticating with Kerberos specify the Kerberos service name. Default is ``hive``. @@ -75,4 +75,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP' + export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?authMechanism=LDAP' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.1/connections/hive_metastore.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.1/connections/hive_metastore.html index ab253fed1aa..a73c59c1868 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.1/connections/hive_metastore.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.1/connections/hive_metastore.html @@ -37,9 +37,9 @@ - + - +
@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -570,22 +570,22 @@ - +
- + @@ -874,4 +874,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.1/connections/hiveserver2.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.1/connections/hiveserver2.html index ee6965539fd..e978a90f1a7 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.1/connections/hiveserver2.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.1/connections/hiveserver2.html @@ -37,9 +37,9 @@ - + - +

@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -570,22 +570,22 @@ - +
- +
@@ -884,4 +884,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_modules/airflow/providers/apache/hive/hooks/hive.html index aa13f616935..a62ed16c2b4 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -35,9 +35,9 @@ - + - +

@@ -193,8 +193,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -568,22 +568,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1079,15 +1079,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not host: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1390,25 +1390,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1416,7 +1416,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1657,23 +1657,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1684,7 +1684,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1759,7 +1759,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1769,7 +1769,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1792,7 +1792,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1814,4 +1814,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_sources/connections/hive_metastore.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_sources/connections/hive_metastore.rst.txt index 45316d4651c..d427398b088 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_sources/connections/hive_metastore.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_sources/connections/hive_metastore.rst.txt @@ -51,7 +51,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Metastore connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the mechanism for authentication. Default is ``NOSASL``. * ``kerberos_service_name`` Specify the kerberos service name. Default is ``hive``. @@ -66,4 +66,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?auth_mechanism=NOSASL' + export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?authMechanism=NOSASL' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_sources/connections/hiveserver2.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_sources/connections/hiveserver2.rst.txt index 1d16177d97e..bd3bc7a0a58 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_sources/connections/hiveserver2.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.2/_sources/connections/hiveserver2.rst.txt @@ -58,7 +58,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Server2 connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the authentication method for PyHive. Choose between ``PLAIN``, ``LDAP``, ``KERBEROS`` or ``Custom``. Default is ``PLAIN``. * ``kerberos_service_name`` If authenticating with Kerberos specify the Kerberos service name. Default is ``hive``. @@ -75,4 +75,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP' + export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?authMechanism=LDAP' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.2/connections/hive_metastore.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.2/connections/hive_metastore.html index 0980c7f8613..7a8fab10e71 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.2/connections/hive_metastore.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.2/connections/hive_metastore.html @@ -37,9 +37,9 @@ - + - +
@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -570,22 +570,22 @@ - +
- + @@ -874,4 +874,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.2/connections/hiveserver2.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.2/connections/hiveserver2.html index c3fed97804c..09468080d88 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.2/connections/hiveserver2.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.2/connections/hiveserver2.html @@ -37,9 +37,9 @@ - + - +

@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -570,22 +570,22 @@ - +
- +
@@ -884,4 +884,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_modules/airflow/providers/apache/hive/hooks/hive.html index f1d28f56069..6251ae739ad 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -37,9 +37,9 @@ - + - +

@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -570,22 +570,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1081,15 +1081,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not host: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1392,25 +1392,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1418,7 +1418,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1659,23 +1659,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1686,7 +1686,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1761,7 +1761,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1771,7 +1771,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1794,7 +1794,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1816,4 +1816,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_sources/connections/hive_metastore.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_sources/connections/hive_metastore.rst.txt index 45316d4651c..d427398b088 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_sources/connections/hive_metastore.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_sources/connections/hive_metastore.rst.txt @@ -51,7 +51,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Metastore connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the mechanism for authentication. Default is ``NOSASL``. * ``kerberos_service_name`` Specify the kerberos service name. Default is ``hive``. @@ -66,4 +66,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?auth_mechanism=NOSASL' + export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?authMechanism=NOSASL' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_sources/connections/hiveserver2.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_sources/connections/hiveserver2.rst.txt index 1d16177d97e..bd3bc7a0a58 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_sources/connections/hiveserver2.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.3/_sources/connections/hiveserver2.rst.txt @@ -58,7 +58,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Server2 connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the authentication method for PyHive. Choose between ``PLAIN``, ``LDAP``, ``KERBEROS`` or ``Custom``. Default is ``PLAIN``. * ``kerberos_service_name`` If authenticating with Kerberos specify the Kerberos service name. Default is ``hive``. @@ -75,4 +75,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP' + export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?authMechanism=LDAP' diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.3/connections/hive_metastore.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.3/connections/hive_metastore.html index 1fcd368c44d..eb88568bfc1 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.3/connections/hive_metastore.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.3/connections/hive_metastore.html @@ -39,9 +39,9 @@ - + - +
@@ -197,8 +197,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -572,22 +572,22 @@ - +
- + @@ -876,4 +876,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/2.3.3/connections/hiveserver2.html b/docs-archive/apache-airflow-providers-apache-hive/2.3.3/connections/hiveserver2.html index 8d7bbe2bac9..6256894e0ab 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/2.3.3/connections/hiveserver2.html +++ b/docs-archive/apache-airflow-providers-apache-hive/2.3.3/connections/hiveserver2.html @@ -39,9 +39,9 @@ - + - +

@@ -197,8 +197,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -572,22 +572,22 @@ - +
- +
@@ -886,4 +886,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html b/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html index acfa71792cf..4353b8c2391 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html +++ b/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_modules/airflow/providers/apache/hive/hooks/hive.html @@ -37,9 +37,9 @@ - + - +

@@ -195,8 +195,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -570,22 +570,22 @@ - +
- +

Source code for airflow.providers.apache.hive.hooks.hive

 #
 # Licensed to the Apache Software Foundation (ASF) under one
@@ -1081,15 +1081,15 @@ 

Source code for airflow.providers.apache.hive.hooks.hive

if not host: raise AirflowException("Failed to locate the valid server.") - auth_mechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') + authMechanism = conn.extra_dejson.get('authMechanism', 'NOSASL') if conf.get('core', 'security') == 'kerberos': - auth_mechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') + authMechanism = conn.extra_dejson.get('authMechanism', 'GSSAPI') kerberos_service_name = conn.extra_dejson.get('kerberos_service_name', 'hive') conn_socket = TSocket.TSocket(host, conn.port) - if conf.get('core', 'security') == 'kerberos' and auth_mechanism == 'GSSAPI': + if conf.get('core', 'security') == 'kerberos' and authMechanism == 'GSSAPI': try: import saslwrapper as sasl except ImportError: @@ -1392,25 +1392,25 @@

Source code for airflow.providers.apache.hive.hooks.hive

db = self.get_connection(self.hiveserver2_conn_id) # type: ignore - auth_mechanism = db.extra_dejson.get('authMechanism', 'NONE') - if auth_mechanism == 'NONE' and db.login is None: + authMechanism = db.extra_dejson.get('authMechanism', 'NONE') + if authMechanism == 'NONE' and db.login is None: # we need to give a username username = 'airflow' kerberos_service_name = None if conf.get('core', 'security') == 'kerberos': - auth_mechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') + authMechanism = db.extra_dejson.get('authMechanism', 'KERBEROS') kerberos_service_name = db.extra_dejson.get('kerberos_service_name', 'hive') - # pyhive uses GSSAPI instead of KERBEROS as a auth_mechanism identifier - if auth_mechanism == 'GSSAPI': + # pyhive uses GSSAPI instead of KERBEROS as a authMechanism identifier + if authMechanism == 'GSSAPI': self.log.warning( "Detected deprecated 'GSSAPI' for authMechanism for %s. Please use 'KERBEROS' instead", self.hiveserver2_conn_id, # type: ignore ) - auth_mechanism = 'KERBEROS' + authMechanism = 'KERBEROS' # Password should be set if and only if in LDAP or CUSTOM mode - if auth_mechanism in ('LDAP', 'CUSTOM'): + if authMechanism in ('LDAP', 'CUSTOM'): password = db.password from pyhive.hive import connect @@ -1418,7 +1418,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

return connect( host=db.host, port=db.port, - auth=auth_mechanism, + auth=authMechanism, kerberos_service_name=kerberos_service_name, username=db.login or username, password=password, @@ -1659,23 +1659,23 @@

Source code for airflow.providers.apache.hive.hooks.hive

- +
- +
- - + + @@ -1686,7 +1686,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1761,7 +1761,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Want to be a part of Apache Airflow? @@ -1771,7 +1771,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

@@ -1794,7 +1794,7 @@

Source code for airflow.providers.apache.hive.hooks.hive

Security - +
@@ -1816,4 +1816,4 @@

Source code for airflow.providers.apache.hive.hooks.hive

- \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_sources/connections/hive_metastore.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_sources/connections/hive_metastore.rst.txt index 45316d4651c..d427398b088 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_sources/connections/hive_metastore.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_sources/connections/hive_metastore.rst.txt @@ -51,7 +51,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Metastore connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the mechanism for authentication. Default is ``NOSASL``. * ``kerberos_service_name`` Specify the kerberos service name. Default is ``hive``. @@ -66,4 +66,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?auth_mechanism=NOSASL' + export AIRFLOW_CONN_METASTORE_DEFAULT='hive-metastore://hive-metastore-node:80?authMechanism=NOSASL' diff --git a/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_sources/connections/hiveserver2.rst.txt b/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_sources/connections/hiveserver2.rst.txt index 1d16177d97e..bd3bc7a0a58 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_sources/connections/hiveserver2.rst.txt +++ b/docs-archive/apache-airflow-providers-apache-hive/3.0.0/_sources/connections/hiveserver2.rst.txt @@ -58,7 +58,7 @@ Extra (optional) Specify the extra parameters (as json dictionary) that can be used in Hive Server2 connection. The following parameters are all optional: - * ``auth_mechanism`` + * ``authMechanism`` Specify the authentication method for PyHive. Choose between ``PLAIN``, ``LDAP``, ``KERBEROS`` or ``Custom``. Default is ``PLAIN``. * ``kerberos_service_name`` If authenticating with Kerberos specify the Kerberos service name. Default is ``hive``. @@ -75,4 +75,4 @@ For example: .. code-block:: bash - export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?auth_mechanism=LDAP' + export AIRFLOW_CONN_HIVESERVER2_DEFAULT='hiveserver2://username:password@hiveserver2-node:80/database?authMechanism=LDAP' diff --git a/docs-archive/apache-airflow-providers-apache-hive/3.0.0/connections/hive_metastore.html b/docs-archive/apache-airflow-providers-apache-hive/3.0.0/connections/hive_metastore.html index 26f9156713d..9d1bc9596a6 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/3.0.0/connections/hive_metastore.html +++ b/docs-archive/apache-airflow-providers-apache-hive/3.0.0/connections/hive_metastore.html @@ -39,9 +39,9 @@ - + - +
@@ -197,8 +197,8 @@
- - + +
- +
- - + +
- - + +
- - + + @@ -572,22 +572,22 @@ - +
- + @@ -876,4 +876,4 @@

Configuring the Connection - \ No newline at end of file + diff --git a/docs-archive/apache-airflow-providers-apache-hive/3.0.0/connections/hiveserver2.html b/docs-archive/apache-airflow-providers-apache-hive/3.0.0/connections/hiveserver2.html index 3c07ffa3605..cea85f049fe 100644 --- a/docs-archive/apache-airflow-providers-apache-hive/3.0.0/connections/hiveserver2.html +++ b/docs-archive/apache-airflow-providers-apache-hive/3.0.0/connections/hiveserver2.html @@ -39,9 +39,9 @@ - + - +

@@ -197,8 +197,8 @@
- - + +
- +