[
https://issues.apache.org/jira/browse/FLINK-18827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantin Knauf updated FLINK-18827:
-------------------------------------
Labels: (was: stale-major)
Removed "stale-critical|major|minor" label in line with
https://issues.apache.org/jira/browse/FLINK-22429.
> 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
>
> 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)
