Re: flink 1.10 support LONG as watermark?
Posted by
jingjing bai on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/flink-1-10-support-LONG-as-watermark-tp33981p34019.html
Thanks a lot!
Hi jarkWu!
Is there a FLIP to do so? I'm very glad to learn from idea.
Best,
jing
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
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.