Команда Spark submit spark-submit --class=com.test.App /home/ubuntu/app.jar /home/ubuntu/abc

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

Я пытаюсь выполнить Spark jar на Dataproc, используя DataProcSparkOperator от Airflow .JAR...

Я новичок в использовании воздушного потока и что мне нужно сделать, это использовать MssqlHook или...

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

Я использовал kubectl для загрузки рабочих процессов Airflow в kubernetes (/ usr / local / airflow...

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

У меня старая версия upstart (0.6.5), и я хочу запустить airflow webserver с upstart. description...

Мы используем Apache луч через воздушный поток.Для учетной записи GCS по умолчанию задана...

Я использую BranchPythonOperator для создания веток в потоке воздуха.Мой пример использования - мне...

Я начал использовать Airflow для планирования рабочих мест в нашей компании, и мне интересно узнать...

Я пытаюсь вставить в xcom значение с помощью ключа last_date в last_date_task, а затем вытащить его...

У меня проблема с воздушным потоком при работе его на 24-часовой машине на EC2. Должен отметить,...

Когда я запускаю программу, я получаю сообщение "Сломанный знак без имени модуля slackclient". Я...

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

Я довольно новичок в воздушном потоке, хотя мне удалось написать код для чтения (хранилище данных)...

У меня есть требование для записи журналов Apache Airflow на стандартный вывод в формате JSON....

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

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

Я пытаюсь планировать задачи в потоке воздуха, но, видимо, это не так очевидно. Задача, которую я...

У меня проблема со связью Spark и Airflow.Хотя я могу запустить свое искровое задание с помощью...

Я запускаю задание Dataflow из Airflow.Я должен сказать, что я новичок в Airflow.Поток данных...

Можно ли как-нибудь безопасно перезапустить Airflow веб-сервер и / или планировщик на сервере? Я...

Я пытаюсь запустить воздушный поток с сельдереем с помощью Redis в качестве брокера, но работа...

У меня есть кластер искр и воздушных потоков, который построен с помощью док-роя.Контейнер...