Jakob Homan created AIRFLOW-5484:
------------------------------------
Summary: PigCliHook has incorrect named parameter
Key: AIRFLOW-5484
URL: https://issues.apache.org/jira/browse/AIRFLOW-5484
Project: Apache Airflow
Issue Type: Bug
Components: hooks
Affects Versions: 1.10.6
Reporter: Jakob Homan
When building the connection hook, we try to assign a variable named
`pig_conn_id`. However, this doesn't exist, the correct name is
`pig_cli_conn_id`. This will cause the correct config to not be picked up.
airflow/models/connection.py:212
{code:java}
elif self.conn_type == 'pig_cli':
from airflow.hooks.pig_hook import PigCliHook
return PigCliHook(pig_conn_id=self.conn_id) {code}
airflow/hooks/pig_hook.py:38
{code:java}
def __init__(
self,
pig_cli_conn_id="pig_cli_default"):
conn = self.get_connection(pig_cli_conn_id)
self.pig_properties = conn.extra_dejson.get('pig_properties', '')
self.conn = conn {code}
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
