Skip to main content
Version: Next

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 and FAIL 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 for FAIL event in Airflow 2.6+ #2305 @kacpermuda
    The Run_id in a FAIL event was different than in the START event for Airflow 2.6+.
  • Flink: open Iceberg TableLoader before loading a table #2314 @pawel-big-lebowski
    Fixes a potential NullPointerException in 1.17 when dealing with Iceberg sinks.
  • Flink: name Kafka datasets according to the naming convention #2321 @pawel-big-lebowski
    Adds a kafka:// 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 the Authority 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.