Мы используем оператор asyn c для выполнения вызовов API, а иногда они не работают. Мы хотели бы повторить то же событие снова через несколько пользовательских интервалов времени. Сбой также может быть вызван некоторой проверкой после вызова, что вызвано кодом. Мы нашли это: https://issues.apache.org/jira/browse/FLINK-11909 Не уверен, что это было реализовано. Если нет, есть ли выход? Возможно, с помощью оператора вниз по цепочке, чтобы pu sh события возвращались к asyn c оператору после задержки? Или просто pu sh события, которые необходимо повторить обратно во входной поток после фильтрации?