This message was deleted Apache Flink #troubleshooting

This message was deleted.

Slackbot

07/05/2023, 6:49 AM

This message was deleted.

David Anderson

07/05/2023, 4:30 PM

The interval join from the DataStream API only supports event time processing, and thus requires watermarks.

✅ 1

David Anderson

07/05/2023, 4:33 PM

You can handle this by using a

Copy code

WatermarkStrategy.forMonotonousTimestamps();

strategy, using a timestamp extractor that returns currentTimeMillis as the timestamp for each event (i.e., using ingestion time semantics).

✅ 1

gratitude thank you 1