[
https://issues.apache.org/jira/browse/AIRFLOW-5484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16941713#comment-16941713
]
ASF subversion and git services commented on AIRFLOW-5484:
----------------------------------------------------------
Commit 145d4c0f50908b48d05e50710c5c40ac000849aa in airflow's branch
refs/heads/v1-10-test from yorologo
[ https://gitbox.apache.org/repos/asf?p=airflow.git;h=145d4c0 ]
AIRFLOW-5484: fix PigCliHook has incorrect named parameter (#6112)
(cherry picked from commit d89002dc4ef657720cbfeeeb6040e9c2aa748f33)
> 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.5
> Reporter: Jakob Homan
> Priority: Minor
> Labels: ccoss2019, newbie
> Fix For: 1.10.6
>
>
> 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.4#803005)
