This is an automated email from the ASF dual-hosted git repository.
eladkal 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 07226795ae Fix assignment of template field in `__init__` in
`hive_to_samba.py` (#36486)
07226795ae is described below
commit 07226795ae5dad41f8a4b8e30b148bba1e0610bd
Author: rom sharon <[email protected]>
AuthorDate: Fri Dec 29 18:35:23 2023 +0200
Fix assignment of template field in `__init__` in `hive_to_samba.py`
(#36486)
---
airflow/providers/apache/hive/transfers/hive_to_samba.py | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/airflow/providers/apache/hive/transfers/hive_to_samba.py
b/airflow/providers/apache/hive/transfers/hive_to_samba.py
index e81e695f47..4f09789e10 100644
--- a/airflow/providers/apache/hive/transfers/hive_to_samba.py
+++ b/airflow/providers/apache/hive/transfers/hive_to_samba.py
@@ -61,9 +61,10 @@ class HiveToSambaOperator(BaseOperator):
self.hiveserver2_conn_id = hiveserver2_conn_id
self.samba_conn_id = samba_conn_id
self.destination_filepath = destination_filepath
- self.hql = hql.strip().rstrip(";")
+ self.hql = hql
def execute(self, context: Context):
+ self.hql = self.hql.strip().rstrip(";")
with NamedTemporaryFile() as tmp_file:
self.log.info("Fetching file from Hive")
hive =
HiveServer2Hook(hiveserver2_conn_id=self.hiveserver2_conn_id)
