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-tp33981.html

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.