apache-airflow
Airflow: Protokolldatei ist nicht lokal, nicht unterstützter Remote-Protokollspeicherort
Airflow-Aufgaben bleiben im Status "In Warteschlange" hängen und werden nie ausgeführt
So stoppen/beenden Sie Airflow-Aufgaben auf der Benutzeroberfläche
So starten Sie eine fehlgeschlagene Task in Airflow neu
Status der Airflow-Aufgabe innerhalb des Tags
Luftstrom: Übergeben Sie {{ds}} als Parameter an PostgresOperator
Apache Airflow DAG kann kein lokales Modul importieren
Airflow-Authentifizierungseinstellungen schlagen mit "AttributeError: Attribut nicht setzen" fehl
Effiziente Methode zum Bereitstellen von DAG-Dateien im Luftstrom
Welche wählen Sie für Apache Oozie oder Apache Airflow? Brauche einen Vergleich
Airflow 1.9.0 steht in der Warteschlange, startet jedoch keine Aufgaben
Airflow Scheduler-Protokolle entfernen
Airbnb Airflow gegen Apache Nifi
Wie führe ich Spark code in Airflow aus?
Luftstrom "Diese DAG ist im Webserver-DagBag-Objekt nicht verfügbar."
Apache Airflow oder Apache Beam für die Datenverarbeitung und Jobplanung
Wie kann ich Apache Airflow mit Slack integrieren?
Airflow SparkSubmitOperator - So senden Sie einen Funken auf einem anderen Server
Encoderfehler beim Versuch, die Datenrahmenzeile der aktualisierten Zeile zuzuordnen
Wie bereiten Sie Daten aus DataFrame in ein LibSVM-Format vor?
Encoder für Zeilentyp Spark Datasets
So führen Sie Airflow unter Windows aus
execution_date in airflow: muss als Variable zugreifen
Auslösen einer Airflow-DAG vom Terminal aus funktioniert nicht
Wie installiere ich den Luftstrom?
Festlegen von Abhängigkeiten zwischen DAGs in Airflow
Luftstrom-Übergabeparameter an abhängige Aufgabe
Wie kann verhindert werden, dass der Luftstrom beim Nachfüllen von Dagläufen erfolgt?
Während airflow initdb kann ImportError: Name HiveOperator nicht importieren
Wie starte ich den airflow webserver neu?
Dynamische DAG und Task-IDs von Airflow
Airflow: SSH und Ausführen von BashOperator von einem anderen Server
Wie verwende ich AirFlow, um einen Ordner mit python Dateien auszuführen?
airflow trigger_dag execution_date ist der nächste tag, warum?
Airflow S3-Verbindung über die Benutzeroberfläche
So führen Sie eine Bash-Skriptdatei in Airflow aus
Airflow: Wie lösche ich eine DAG?
So erstellen Sie dynamische Workflows in Airflow
Luftstrom mit Vorlagendateien für PythonOperator
Ausführen einer einfachen Luftstrom-DAG
Apache Airflow: Kontrolle über die Protokollierung [Protokollierungsstufe deaktivieren/anpassen]
Ausführen eines Jobs bei Airflow basierend auf Webrequest
Luftstrom: dag_id wurde nicht gefunden
So entfernen Sie Standardbeispielfehler im Luftstrom
Beispiel: DAG bleibt auf unbestimmte Zeit im "laufenden" Zustand
Luftstrom: Aufgaben in der Warteschlange, werden jedoch nicht ausgeführt
Airflow-Aufgabenprotokolle entfernen
So erstellen Sie eine bedingte Aufgabe in Airflow
Airflow-Plugins können nicht importiert werden
s3 für Protokolle im Luftstrom einrichten
Speichern und greifen Sie auf das Passwort mit Apache Airflow zu
Airflow - Übergabe der xcom-Variablen an die Python function
Airflow-Aufgaben können aufgrund des Ausführungsdatums und des Startdatums nicht ausgeführt werden
docker-Compose Unbekannter MySQL-Server Host 'mysql' (Luftstrom)
Dynamische Aufgabendefinition in Airflow
Luftstrom + Sellerie oder Dask. Für was, wann?
So führen Sie Airflow PythonOperator in einer virtuellen Umgebung aus
Wie wähle ich meine Airflow- oder Python-Version mit Cloud Composer aus?
Python Airflow - Gibt das Ergebnis von PythonOperator zurück
Airflow protokolliert BrokenPipeException
Wie richte ich Airflow ein? E-Mail senden?
Apache-Airflow in der Conda-Umgebung installieren
Apache Airflow: Luftstrom initdb führt zu "ImportError: Kein Modul namens json"
Der Luftstromplaner scheint nach dem Ausführen einer Aufgabe nicht ausgeführt zu werden
Apache-Luftstrom kann nach Neuinstallation nicht ausgeführt werden, python Importfehler
Fehler beim Installieren von Apache-airflow
variable/Parameter in Spark SQL dynamisch binden?
So erstellen Sie einen korrekten Datenrahmen für die Klassifizierung in Spark ML
Unterschied zwischen DataFrame, Dataset und RDD in Spark
Wie werden kategoriale Funktionen mit spark-ml behandelt?
DataFrame-Join-Optimierung - Broadcast-Hash-Join
"INSERT INTO ..." mit SparkSQL HiveContext
Spark 1.6: Filtern von DataFrames, die von "compare ()" generiert wurden
Warum wird SparkContext zufällig geschlossen und wie wird es von Zeppelin aus neu gestartet?
Wie werden benutzerdefinierte Objekte in Dataset gespeichert?
Sollten wir einen DataFrame so parallelisieren, wie wir einen Seq vor dem Training parallelisieren?
So erstellen Sie einen benutzerdefinierten Encoder in Spark 2.X-Datensätzen
So teilen Sie Vector in Spalten - mit PySpark
Was ist der Unterschied zwischen Spark ML- und MLLIB-Paketen?
Lesen von CSV-Dateien mit Feldern in Anführungszeichen, die eingebettete Kommas enthalten
Führen Sie einen getippten Join in Scala mit Spark-Datensätzen durch
Der Wert der Einstellung "spark.yarn.executor.memoryOverhead"?
Wie konvertiere ich eine Array (d. H. Liste) -Spalte in Vector
Wie konvertiere ich die Datensätze von Spark Row in einen String?
Wie wird die Groß- / Kleinschreibung der gesamten Spalte geändert?
Was sind die Vorteile von Apache Beam gegenüber Spark / Flink für die Stapelverarbeitung?