при локальном запуске потоков и передаче несуществующего локального адреса в качестве входных данных (т. Е. URL несуществующего файла), параметр проверки ReadFromText работает отлично и выдает ошибку. Однако поток не выдает никакой ошибки при работе на GCP (адрес GCS в качестве ввода). Под этим я подразумеваю, что параметр validate не имеет никакого эффекта, и процесс продолжается, как будто передается существующий файл с пустым текстом внутри. Есть ли обходной путь для этого?
конвейер луча apache в потоке данных GCP
Я ожидаю, что возникнет ошибка, поэтому поток должен завершиться сбоем. Но поток продолжается с пустой коллекцией молча.