(airflow) branch main updated: Setting use_beeline by default for hive cli connection (#38763)

[amoghdesai]

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 6e0ac39764 Setting use_beeline by default for hive cli connection 
(#38763)
6e0ac39764 is described below

commit 6e0ac3976491679ab99e116d41846f0c1261abaa
Author: Amogh Desai <amoghrajesh1...@gmail.com>
AuthorDate: Tue Apr 9 14:09:10 2024 +0530

    Setting use_beeline by default for hive cli connection (#38763)
    
    Co-authored-by: Elad Kalif <45845474+elad...@users.noreply.github.com>
    Co-authored-by: Jarek Potiuk <ja...@potiuk.com>
---
 airflow/providers/apache/hive/CHANGELOG.rst    | 10 ++++++++++
 airflow/providers/apache/hive/hooks/hive.py    |  2 +-
 airflow/providers/apache/hive/provider.yaml    |  1 +
 tests/providers/apache/hive/hooks/test_hive.py | 12 ++++++++++++
 4 files changed, 24 insertions(+), 1 deletion(-)

diff --git a/airflow/providers/apache/hive/CHANGELOG.rst 
b/airflow/providers/apache/hive/CHANGELOG.rst
index 4522c3f2e4..2db27e19fd 100644
--- a/airflow/providers/apache/hive/CHANGELOG.rst
+++ b/airflow/providers/apache/hive/CHANGELOG.rst
@@ -27,6 +27,16 @@
 Changelog
 ---------
 
+8.0.0
+.....
+
+
+Breaking changes
+~~~~~~~~~~~~~~~~
+
+Changed the default value of ``use_beeline`` in hive cli connection to True.
+Beeline will be always enabled by default in this connection type.
+
 7.0.1
 .....
 
diff --git a/airflow/providers/apache/hive/hooks/hive.py 
b/airflow/providers/apache/hive/hooks/hive.py
index c33c59dd5f..b3234fee4f 100644
--- a/airflow/providers/apache/hive/hooks/hive.py
+++ b/airflow/providers/apache/hive/hooks/hive.py
@@ -126,7 +126,7 @@ class HiveCliHook(BaseHook):
         from wtforms import BooleanField, StringField
 
         return {
-            "use_beeline": BooleanField(lazy_gettext("Use Beeline"), 
default=False),
+            "use_beeline": BooleanField(lazy_gettext("Use Beeline"), 
default=True),
             "proxy_user": StringField(lazy_gettext("Proxy User"), 
widget=BS3TextFieldWidget(), default=""),
             "principal": StringField(
                 lazy_gettext("Principal"), widget=BS3TextFieldWidget(), 
default="hive/_h...@example.com"
diff --git a/airflow/providers/apache/hive/provider.yaml 
b/airflow/providers/apache/hive/provider.yaml
index 79a7f19667..ad31de88ec 100644
--- a/airflow/providers/apache/hive/provider.yaml
+++ b/airflow/providers/apache/hive/provider.yaml
@@ -25,6 +25,7 @@ state: ready
 source-date-epoch: 1709554960
 # note that those versions are maintained by release manager - do not update 
them manually
 versions:
+  - 8.0.0
   - 7.0.1
   - 7.0.0
   - 6.4.2
diff --git a/tests/providers/apache/hive/hooks/test_hive.py 
b/tests/providers/apache/hive/hooks/test_hive.py
index e444697bf6..f81d31a04c 100644
--- a/tests/providers/apache/hive/hooks/test_hive.py
+++ b/tests/providers/apache/hive/hooks/test_hive.py
@@ -870,6 +870,18 @@ class TestHiveCli:
     def setup_method(self):
         self.nondefault_schema = "nondefault"
 
+    def test_default_values(self):
+        hook = MockHiveCliHook()
+
+        assert hook.use_beeline
+        assert hook.auth is None
+        assert hook.sub_process is None
+        assert hook.mapred_queue == "airflow"
+        assert hook.mapred_queue_priority is None
+        assert hook.mapred_job_name is None
+        assert hook.proxy_user is None
+        assert not hook.high_availability
+
     @pytest.mark.parametrize(
         "extra_dejson, correct_proxy_user, proxy_user",
         [