You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by am...@apache.org on 2024/05/16 17:42:32 UTC
(airflow) branch main updated: Improvising high availability field name in hive hook (#39658)
This is an automated email from the ASF dual-hosted git repository.
amoghdesai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new ea8ed7c43f Improvising high availability field name in hive hook (#39658)
ea8ed7c43f is described below
commit ea8ed7c43f7b25cb2ee2f75f9b857569aa09c7ff
Author: Amogh Desai <am...@gmail.com>
AuthorDate: Thu May 16 23:12:26 2024 +0530
Improvising high availability field name in hive hook (#39658)
* Improvising high availability field name in hive hook
* updating per hussein's suggestion
Co-authored-by: Hussein Awala <hu...@awala.fr>
---------
Co-authored-by: Hussein Awala <hu...@awala.fr>
---
airflow/providers/apache/hive/hooks/hive.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/airflow/providers/apache/hive/hooks/hive.py b/airflow/providers/apache/hive/hooks/hive.py
index e6bc336938..eb38ae559b 100644
--- a/airflow/providers/apache/hive/hooks/hive.py
+++ b/airflow/providers/apache/hive/hooks/hive.py
@@ -128,7 +128,7 @@ class HiveCliHook(BaseHook):
"principal": StringField(
lazy_gettext("Principal"), widget=BS3TextFieldWidget(), default="hive/_HOST@EXAMPLE.COM"
),
- "high_availability": BooleanField(lazy_gettext("High Availability"), default=False),
+ "high_availability": BooleanField(lazy_gettext("High Availability mode"), default=False),
}
@classmethod
@@ -160,10 +160,10 @@ class HiveCliHook(BaseHook):
self._validate_beeline_parameters(conn)
if self.high_availability:
jdbc_url = f"jdbc:hive2://{conn.host}/{conn.schema}"
- self.log.info("High Availability set, setting JDBC url as %s", jdbc_url)
+ self.log.info("High Availability selected, setting JDBC url as %s", jdbc_url)
else:
jdbc_url = f"jdbc:hive2://{conn.host}:{conn.port}/{conn.schema}"
- self.log.info("High Availability not set, setting JDBC url as %s", jdbc_url)
+ self.log.info("High Availability not selected, setting JDBC url as %s", jdbc_url)
if conf.get("core", "security") == "kerberos":
template = conn.extra_dejson.get("principal", "hive/_HOST@EXAMPLE.COM")
if "_HOST" in template: