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.
