You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airflow.apache.org by "Aizhamal Nurmamat kyzy (JIRA)" <ji...@apache.org> on 2019/05/17 20:04:01 UTC

[jira] [Updated] (AIRFLOW-4076) Correct beeline_default port type in initdb function

     [ https://issues.apache.org/jira/browse/AIRFLOW-4076?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Aizhamal Nurmamat kyzy updated AIRFLOW-4076:
--------------------------------------------
    Component/s:     (was: db)
                 database

> Correct beeline_default port type in initdb function
> ----------------------------------------------------
>
>                 Key: AIRFLOW-4076
>                 URL: https://issues.apache.org/jira/browse/AIRFLOW-4076
>             Project: Apache Airflow
>          Issue Type: Improvement
>          Components: database
>    Affects Versions: 1.10.2
>            Reporter: zhongjiajie
>            Assignee: zhongjiajie
>            Priority: Trivial
>             Fix For: 1.10.3
>
>
> `beeline_default` conn_id create with command `airflow initdb` use String as port type
> {code:java}
> merge_conn(
>     Connection(
>         conn_id='beeline_default', conn_type='beeline', port="10000", <== HERE
>         host='localhost', extra="{\"use_beeline\": true, \"auth\": \"\"}",
>         schema='default'))
> {code}
> but `airflow.models.connection` use int type to store port
> {code:java}
> class Connection(Base, LoggingMixin):
>     __tablename__ = "connection"
>     id = Column(Integer(), primary_key=True)
>     conn_id = Column(String(ID_LEN))
>     conn_type = Column(String(500))
>     host = Column(String(500))
>     schema = Column(String(500))
>     login = Column(String(500))
>     _password = Column('password', String(5000))
>     port = Column(Integer())                     <== HERE
>     is_encrypted = Column(Boolean, unique=False, default=False)
>     is_extra_encrypted = Column(Boolean, unique=False, default=False)
>     _extra = Column('extra', String(5000))
> {code}
> It's could be transfer str to int, but I think is better to pass int values



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)