Hi, Why this combination is not possible? even though I am setting "assignTimestampsAndWatermarks “ correctly on the DataStream.
I would like Flink to be ticking on processing time, but also utilize the TumblingEventTimeWindows which is based on event time. It is not possible because of : java.lang.RuntimeException: Record has Long.MIN_VALUE timestamp (= no timestamp marker). Regards, -Rami Disclaimer: This message and any attachments thereto are intended solely for the addressed recipient(s) and may contain confidential information. If you are not the intended recipient, please notify the sender by reply e-mail and delete the e-mail (including any attachments thereto) without producing, distributing or retaining any copies thereof. Any review, dissemination or other use of, or taking of any action in reliance upon, this information by persons or entities other than the intended recipient(s) is prohibited. Thank you.
