[FLINK-18827] The time attribute is lost when constructing a Table via TableEnvironment.from

• Type: Sub-task
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.11.0
• Component/s: Table SQL / API
• Assignee: Unassigned
• Reporter: Dian Fu
• Created: 05/Aug/20 09:41
• Updated: 28/Dec/20 11:29

Description

For the following job:

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)

the schema of table "orders" is as following:

root
 |-- a: STRING
 |-- b: BIGINT
 |-- c: BIGINT
 |-- rowtime: TIMESTAMP(3)
 |-- WATERMARK FOR rowtime AS `rowtime` - INTERVAL '1' SECOND

We can see that the type of field 'rowtime' is regular TIMESTAMP which is not expected.