Я последовал примеру записи файла AVRO в Документация по Beam . Но это дает мне ошибку Caused by:...

У меня есть задание Google Cloud Dataflow, с помощью которого я хотел бы извлечь именованные...

Я пытаюсь запустить задание DataFlow из DAG Airflow с использованием DataflowTemplateOperator. В...

Сбой задания воздушного потока после обнаружения успешного задания потока данных как зомби. Я...

В кластерной высокопроизводительной вычислительной среде, такой как Облачный поток данных Google...

Как можно узнать, какая версия библиотеки не-Python установлена ​​в потоке данных?Например,...

Я отправляю задание потока данных через airflow v1.10.0 (установлен на локальном компьютере)...

При отправке задания потока данных из воздушного потока, он не может получить статус успеха задания...

Я пытаюсь обработать JIK-дамп Wikidata с помощью Cloud Dataflow. Я скачал файл с https://dumps

У меня есть группа доступности базы данных, которая выполняет 3 конвейера потока данных.Я установил...

В настоящее время я использую экземпляр airflow (1.9.0) на python 3.6.5. У меня есть ручной рабочий...

Я создаю почасовую задачу в Airflow, которая планирует задание потока данных, однако ловушка,...

Я пытаюсь получить самую старую ячейку определенной строки в BigTable в моем конвейере DataFlow...