Hi A.V.,
*//When I run below code I get this error: Caused by:
java.lang.RuntimeException: Rowtime timestamp is null. //Please make sure
that a proper TimestampAssigner is defined and the stream environment uses
the EventTime time characteristic.*
You need to assign Timestamp and watermarks to d
Hi,
I try to create a tumbling time window of 2 rows each in Flink Java. This must
based on the dateTime (TimeStamp3 datatype) or unixDateTime(BIGINT datatype)
column. I've added below the code of two different code versions. The error
messages I get I placed above the code.
When I print the
