В Apache Flink я использую функцию RichAsync для обогащения данных. В случае ошибок / исключений я хочу направить эти записи об ошибках в поток ошибок. Я вижу, что другие функции имеют «побочный вывод» для такого рода сценариев, но как это обрабатывается в RichAsyncFunction? Я также вижу использование ResultFuture <>. CompleteExceptionally, но что это делает или означает, когда это происходит? Останавливается ли поток, он просто регистрируется, в каком состоянии находится выходной элемент потока? Все документы, кажется, просто указывают, как обрабатывать счастливый путь или вызывать completeExceptionly без объяснения того, что происходит дальше. Как правильно обрабатывать / регистрировать ошибки в RichAsyncFunction?
Спасибо!