1.7.0 - 2023-12-21
COMPATIBILITY NOTICE
Starting in 1.7.0, the Airflow integration will no longer support Airflow versions >=2.8.0
.
Please use the OpenLineage Airflow Provider instead.
Added
- Airflow: add parent run facet to
COMPLETE
andFAIL
events in Airflow integration#2320
@kacpermuda
Adds a parent run facet to all events in the Airflow integration.
Fixed
- Airflow: repair up.sh for MacOS
#2316
#2318
@kacpermuda
Some scripts were not working well on MacOS. This adjusts them. - Airflow: repair
run_id
forFAIL
event in Airflow 2.6+#2305
@kacpermuda
TheRun_id
in aFAIL
event was different than in theSTART
event for Airflow 2.6+. - Flink: open Iceberg
TableLoader
before loading a table#2314
@pawel-big-lebowski
Fixes a potentialNullPointerException
in 1.17 when dealing with Iceberg sinks. - Flink: name Kafka datasets according to the naming convention
#2321
@pawel-big-lebowski
Adds akafka://
prefix to Kafka topic datasets' namespaces. - Flink: fix properties within
JobTypeJobFacet
#2325
@pawel-big-lebowski
Fixes properties assignment in the Flink visitor. - Spark: fix
commons-logging
relocate in target jar#2319
@pawel-big-lebowski
Avoids relocating a dependency that was getting excluded from the jar. - Spec: fix inconsistency with Redshift authority format
#2315
@davidjgoss
Amends theAuthority
format for consistency with other references in the same section.
Removed
- Airflow: remove Airflow 2.8+ support
#2330
@kacpermuda
If the Airflow version is>=2.8.0
, the Airflow integration's plugin does not import the integration's listener, disabling the external integration.
Please use the OpenLineage Airflow Provider instead.