Hi
报错信息是query的schema和sink table 的schema信息不匹配,
> tumble_start(proctimeField, INTERVAL '10' SECOND) as tum
是保留时间属性的,对应的类型是TimeIndicatorTypeInfo, 如果要转到TIMSTAMP,你可以在输出前,
cast下tum字段的类型到TIMESTAMP(3)
祝好
Leonard
版本: 1.10.1
引擎:flink
先创建的table表schema如下:
-- root
|-- address: STRING
|-- tum: TIMESTAMP(3)
|-- tum_count: BIGINT
table2表schema如下:
root
|-- name: STRING
|-- age: STRING
|-- field_time: TIMESTAMP(3)
|-- address: STRING
|-- proctimeField: TIMESTAMP(3)
其中proctimeField是PROCTIME
然后执行sql如下:
版本: 1.10.1
引擎:flink
先创建的table表schema如下:
-- root
|-- address: STRING
|-- tum: TIMESTAMP(3)
|-- tum_count: BIGINT
table2表schema如下:
root
|-- name: STRING
|-- age: STRING
|-- field_time: TIMESTAMP(3)
|-- address: STRING
|-- proctimeField: TIMESTAMP(3)
其中proctimeField是PROCTIME
然后执行sql如下: