diff --git a/airflow/providers/apache/hive/CHANGELOG.rst b/airflow/providers/apache/hive/CHANGELOG.rst index 4522c3f2e4599..2db27e19fdbb9 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 c33c59dd5f6db..b3234fee4fa06 100644 --- a/airflow/providers/apache/hive/hooks/hive.py +++ b/airflow/providers/apache/hive/hooks/hive.py @@ -126,7 +126,7 @@ def get_connection_form_widgets(cls) -> dict[str, Any]: 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/_HOST@EXAMPLE.COM" diff --git a/airflow/providers/apache/hive/provider.yaml b/airflow/providers/apache/hive/provider.yaml index 79a7f1966733e..ad31de88ec5db 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 e444697bf69bd..f81d31a04c316 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", [