From 099afc83a7b92f7187cbc1fc1957133150ba7507 Mon Sep 17 00:00:00 2001 From: Maxime Date: Thu, 9 Jul 2015 17:32:52 +0000 Subject: [PATCH] Fixing a bad attr name in HiveToMySqlTransfer --- airflow/operators/hive_to_mysql.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/airflow/operators/hive_to_mysql.py b/airflow/operators/hive_to_mysql.py index 43071deb926a7..c989bd2193789 100644 --- a/airflow/operators/hive_to_mysql.py +++ b/airflow/operators/hive_to_mysql.py @@ -36,7 +36,7 @@ def __init__( self, sql, mysql_table, - hive_cli_conn_id='hiveserver2_default', + hiveserver2_conn_id='hiveserver2_default', mysql_conn_id='mysql_default', mysql_preoperator=None, *args, **kwargs): @@ -44,11 +44,11 @@ def __init__( self.sql = sql self.mysql_table = mysql_table self.mysql_conn_id = mysql_conn_id - self.hive_cli_conn_id = hive_cli_conn_id self.mysql_preoperator = mysql_preoperator + self.hiveserver2_conn_id = hiveserver2_conn_id def execute(self, context): - hive = HiveServer2Hook(hiveserver2_conn_id=self.hive_cli_conn_id) + hive = HiveServer2Hook(hiveserver2_conn_id=self.hiveserver2_conn_id) logging.info("Extracting data from Hive") results = hive.get_records(self.sql)