[
https://issues.apache.org/jira/browse/FLINK-18827?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17327704#comment-17327704
]
Flink Jira Bot commented on FLINK-18827:
----------------------------------------
This major issue is unassigned and itself and all of its Sub-Tasks have not
been updated for 30 days. So, it has been labeled "stale-major". If this ticket
is indeed "major", please either assign yourself or give an update. Afterwards,
please remove the label. In 7 days the issue will be deprioritized.
> The time attribute is lost when constructing a Table via TableEnvironment.from
> ------------------------------------------------------------------------------
>
> Key: FLINK-18827
> URL: https://issues.apache.org/jira/browse/FLINK-18827
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / API
> Affects Versions: 1.11.0
> Reporter: Dian Fu
> Priority: Major
> Labels: stale-major
>
> For the following job:
> {code}
> val t_env = TableEnvironment.create(new
> EnvironmentSettings.Builder().inBatchMode().useBlinkPlanner().build())
> val sourceDdl = """
> create table Orders(
> a VARCHAR,
> b BIGINT,
> c BIGINT,
> rowtime TIMESTAMP(3),
> WATERMARK FOR rowtime AS rowtime - INTERVAL '1' SECOND
> ) with (
> 'connector' = 'filesystem',
> 'format' = 'csv',
> 'path' = '/tmp'
> )"""
> t_env.executeSql(sourceDdl)
> val orders = t_env.from("Orders")
> print(orders.getSchema)
> {code}
> the schema of table "orders" is as following:
> {code}
> root
> |-- a: STRING
> |-- b: BIGINT
> |-- c: BIGINT
> |-- rowtime: TIMESTAMP(3)
> |-- WATERMARK FOR rowtime AS `rowtime` - INTERVAL '1' SECOND
> {code}
> We can see that the type of field 'rowtime' is regular TIMESTAMP which is not
> expected.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
