Re: FlinkSQL 1.10 DDL无法指定水印

2020-03-11 文章 Jark Wu
Benchao is right. 嵌套字段是无法直接访问的,需要逐级引用到。 On Thu, 12 Mar 2020 at 00:45, Benchao Li wrote: > Hi 周炎, > > 你的`date` 和 `time`都是在嵌套结构内部的字段,需要用*request.`value`.`date`*和* > request.`value`.`time`*来使用它们。 > > 周炎 于2020年3月11日周三 下午5:42写道: > > > DDL语句如下: > > CREATE TABLE ods_usage_naga_dsp_filter ( > > re

Re: FlinkSQL 1.10 DDL无法指定水印

2020-03-11 文章 Benchao Li
Hi 周炎, 你的`date` 和 `time`都是在嵌套结构内部的字段,需要用*request.`value`.`date`*和* request.`value`.`time`*来使用它们。 周炎 于2020年3月11日周三 下午5:42写道: > DDL语句如下: > CREATE TABLE ods_usage_naga_dsp_filter ( > request row<`value` row varchar,reqid varchar,source varchar,`time` varchar,`filter` > array> >>>, > event_

FlinkSQL 1.10 DDL无法指定水印

2020-03-11 文章 周炎
DDL语句如下: CREATE TABLE ods_usage_naga_dsp_filter ( request row<`value` row> >>>, event_ts as to_timestamp(concat(`date`,`time`),'-MM-ddHH:mm:ss'), WATERMARK FOR event_ts AS event_ts - interval '60' second )WITH ( 'connector.type' = 'kafka', 'format.fail-on-missing-field'='false', 'co