Re: Field types of query result and registered TableSink 'table' do not match.

2020-09-28 文章 Leonard Xu
Hi 报错信息是query的schema和sink table 的schema信息不匹配, > tumble_start(proctimeField, INTERVAL '10' SECOND) as tum 是保留时间属性的,对应的类型是TimeIndicatorTypeInfo, 如果要转到TIMSTAMP,你可以在输出前, cast下tum字段的类型到TIMESTAMP(3) 祝好 Leonard

Field types of query result and registered TableSink 'table' do not match.

2020-09-27 文章 smallwong
版本: 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如下:

Field types of query result and registered TableSink 'table' do not match.

2020-09-27 文章 smallwong
版本: 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如下: