Hi Team,
We are generating multiple side-output tags and using default processing time
on non-keyed stream. The class $YYY extends ProcessFunction and
implementation is provided for processElement method. Upon sending valid data,
it gives error "Invalid timestamp: -9223372036854775808. Time
Sent: Monday, January 11, 2021 6:50 PM
To: Priyanka Kalra A
Cc: user ; Sushil Kumar Singh B
; Anuj Kumar Jain A
; Chirag Dewan ;
Pankaj Kumar Aggarwal
Subject: Re: Timestamp Issue with OutputTags
Can you please share your code?
On Mon, Jan 11, 2021, 6:47 PM Priyanka Kalra A
mailto:priy
Hi Till,
I’m using Flink 1.11.2 version.
Yes, FlinkKafkaProducer011.setWriteTimestampToKafka(true) was set and causing
the issue.
Thank you for your help!
Regards,
Priyanka
From: Till Rohrmann
Sent: Tuesday, January 12, 2021 3:10 PM
To: Taher Koitawala
Cc: Priyanka Kalra A ; user
