[
https://issues.apache.org/jira/browse/AIRFLOW-4076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16791414#comment-16791414
]
ASF subversion and git services commented on AIRFLOW-4076:
----------------------------------------------------------
Commit e2f138e180376e721326dfcd22f21da720200913 in airflow's branch
refs/heads/master from zhongjiajie
[ https://gitbox.apache.org/repos/asf?p=airflow.git;h=e2f138e ]
[AIRFLOW-4076] Correct port type of beeline_default in init_db (#4908)
airflow initdb will create default beeline connection
with port "10000", but airflow.models.connection
variable port is Integer type. It's better to set
values in same type as int although it could auto
transfer
> 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: db
> 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)
