Why does PyFlink give me a time in the past
I have a Kafka topic in which I produce an entry every 2-3 seconds
Then I have PyFlink job that will format the entries and send them to a db
I have a Kafka topic in which I produce an entry every 2-3 seconds
Then I have PyFlink job that will format the entries and send them to a db