Задание потока данных, кажется, застряло, потому что нет рабочего действия
Я использую работу потока данных и сталкиваюсь с трудностями. У меня есть специальный пакет, который вызывает setup.pyи объявить его в параметрах параметров, как "--setup_file", "./setup.py"
Когда я запускаю задание потока данных, все выглядит нормально, пока через час не появится ошибка уведомления, как показано ниже:
Ошибка: конвейер потока данных не выполнен. Состояние: СБОЙ, Ошибка: рабочий процесс не выполнен. Причины: Задание потока данных, кажется, застряло, потому что в течение 1 часа не было замечено ни одной рабочей активности. Вы можете получить помощь по облачному потоку данных по адресу https://cloud.google.com/dataflow/support.
Мне любопытно, что проблема заключается в том, что в настройках нестандартного пакета "что-то" может быть пропущено (но в неполном пакете нет ошибок). Итак, в чем может быть проблема? и как справиться с этим? Я использую это:
google-cloud-bigquery==0.25.0
google-cloud-core==0.28.1
google-cloud-dataflow==2.5.0