Hi jarkWu! Is there a FLIP to do so? I'm very glad to learn from idea.
Best, jing Jark Wu <imj...@gmail.com> 于2020年3月30日周一 下午6:52写道： > Hi Jingjing, > > Event time field must be a TIMESTAMP(3) type. You can convert your Long > type value into TIMESTAMP(3) using user-defined function. > I'm sorry that Flink doesn't provide built-in function for this purpose, > but will have one soon. > > For example: > CREATE TABLE myTable ( > log_ts bigint, > event_time AS my_func(log_ts), > WATERMARK FOR event_time AS event_time - INTERVAL '1' SECOND > ) WITH ( > ... > ); > > Here my_func is a UDF which converts BIGINT into TIMESTAMP(3). > > Best, > Jark > > On Mon, 30 Mar 2020 at 18:16, jingjing bai <baijingjing7...@gmail.com> > wrote: > >> >> Hi: >> flinkers! >> >> I try to upgrade our production to 1.10V from 1.9 which is our current >> product version. >> in our case,the event_time is Long ,and we had implement this function >> which support long type as a watermark in our inner version, it is a >> different from the official version on 1.10. >> on 1.10 version, flink had add watermark definition and I had drop our >> implement. >> and i encounter this problem too , >> >> how can I do in new version, if is , I 'm not to migrate our inner >> implement to new version. >> >> >>
