Flink CEP: Как проверить, не появилось ли следующее событие в заданном временном окне?

Я пытаюсь выяснить, как реализовать следующую логику с потоком событий:

1. Первое событие появляется в заданном временном окне (30 с)
2. Второе событие, связанное с первым (по какому-то свойству) не появилось в заданном временном окне
3. Создать новое событие ошибки

В настоящее время я реализовал "противоположную" реализацию, которая была довольно простой:

stream.begin('first').where({conditions}).next('second').where({conditions}).within(Time.seconds(30))