Я хотел бы использовать ошибку, чтобы поймать все ошибки, которые случаются во время моего конвейера.
Я видел, что есть интерфейс, который позволяет сделать это: https://beam.apache.org/releases/javado ... andler.hml
Подробнее здесь: https://stackoverflow.com/questions/796 ... pache-beam
