Hi Faye,
the problem lies in the wrong design of JDK's java.sql.Timestamp. You
can also find a nice summary in the answer here [1]. java.sql.Timestamp
is timezone dependent. Internally, we subtract/normalize the timezone
and work with the UNIX timestamp. Beginning from Flink 1.9 we are using
Hello,
I am having an issue with Event time stamp and timezone with Flink 1.8 (1.8
because I need it to work on AWS Kinesis)
I have a very simple pipeline that read events from a stream, transform to a
Table does a small window (Tumblin 1 min) aggregation and groupby, transforms
back to a stre
