В версии 2.1 луча apache, когда поток данных не находит файлы в GCS облачной платформы Google, он генерирует исключение FileNotFound и останавливает выполнение.
начиная с версии 2.2, даже если поток данных не находит файлы, он продолжает выполнение.
существует ли простой способ остановить поток данных, когда файлы не существуют в GCS, даже если используется версия 2.2 apache beam?