- Spark: compile & test Spark integration on Java 17.
#2828
@pawel-big-lebowski
Spark integration is always compiled with Java 17, while tests are running on both Java 8 and Java 17 according to the configuration. - Spark: Support preview release of Spark 4.0 .
#2854
@pawel-big-lebowski
Include Spark 4.0 preview release in the integration tests. - Spark: add handling for
Window
#2901
@tnazarew
Adds handling forWindow
-type nodes of a logical plan.
- Spark: fix issue with kafka source when saving with for each batch method
#2868
@imbruced
Fixes issue when spark is in the streaming mode, then kafka input is in project plan which was filtered, hence input for kafka was not present in the event
1.19.0 - 2024-07-22
- Airflow: add
log_url
toAirflowRunFacet
#2852
@dolfinus
Adds taskinstance'slog_url
field toAirflowRunFacet
. - Spark: add handling for
Generate
#2856
@tnazarew
Adds handling forGenerate
-type nodes of a logical plan (e.g., explode operations). - Java: add
DerbyJdbcExtractor
#2869
@dolfinus
AddsJdbcExtractor
implementation for Derby database. As this is a file-based DBMS, its Dataset namespace isfile
and name is an absolute path to a database file. - Spark: verify bytecode version of the built jar.
#2859
@pawel-big-lebowski
Extends theJarVerifier
plugin to ensure all compiled classes have a bytecode version of Java 8 or lower. - Spark: add Kafka streaming source support
#2851
@d-m-h @imbruced
Adds support for Kafka streaming sources to Kafka streaming sinks. Inputs and outputs are now included in lineage events.
- Airflow: replace datetime.now with airflow.utils.timezone.utcnow
#2865
@kacpermuda
Fixes missing timezone information in task FAIL events. - Spark: remove shaded dependency in
ColumnLevelLineageBuilder
#2850
@tnazarew
Removes the shadedStreams
dependency inColumnLevelLineageBuilder
causing aClassNotFoundException
. - Spark: make Delta dataset symlink consistent with non-Delta tables
#2863
@dolfinus
Makes dataset symlinks for Delta and non-Delta tables consistent. - Spark: use Table's properties during column-level lineage construction
#2855
@ddebowczyk92
FixesPlanUtils3
so Dataset identifier information based on a Table's properties is also retrieved during the construction of column-level lineage. - Spark: extract job name creation to providers
#2861
@arturowczarek
The integration now detects if thespark.app.name
was autogenerated by Glue and uses the Glue job name in such cases. Also, each job name provisioning strategy is now extracted to a separate provider.
1.18.0 - 2024-07-11
- Spark: configurable integration test
#2755
@pawel-big-lebowski
Provides command line tool capable of running Spark integration tests that can be created without Java. - Spark: OpenLineage Spark extension interfaces without runtime dependency hell
#2809
#2837
@ddebowczyk92
New Spark extension interfaces without runtime dependency hell. Includes a test to verify the integration is working properly. - Spark: support latest versions 3.4.3 and 3.5.1.
#2743
@pawel-big-lebowski
Upgrades CI workflows to run tests against latest Spark versions: 3.4.2 -> 3.4.3 and 3.5.0 -> 3.5.1. - Spark: add extraction of the masking property in column-level lineage
#2789
@tnazarew
Adds extraction of the masking property during collection of dependencies forColumnLineageDatasetFacet
creation. - Spark: collect table name from
InsertIntoHadoopFsRelationCommand
#2794
@dolfinus
Collects a table name forINSERT INTO
command for tables created withUSING $fileFormat
syntax, likeUSING orc
. - Spark, Flink: add
PostgresJdbcExtractor
#2806
@dolfinus
Adds the default5432
port to Postgres namespaces. - Spark, Flink: add
TeradataJdbcExtractor
#2826
@dolfinus
Converts JDBC URLs likejdbc:teradata/host/DBS_PORT=1024,DATABASE=somedb
to datasets with namespaceteradata://host:1024
and namesomedb.table
. - Spark, Flink: add
MySqlJdbcExtractor
#2825
@dolfinus
Handles different formats of MySQL JDBC URL, and produces datasets with consistent namespaces, likemysql://host:port
. - Spark, Flink: add
OracleJdbcExtractor
#2824
@dolfinus
Handles simple Oracle JDBC URLs, likeoracle:thin:@//host:port/serviceName
andoracle:thin@host:port:sid
, and converts each to a dataset with namespaceoracle://host:port
and namesid.schema.table
orserviceName.schema.table
. - Spark: configurable test with Docker image provided
#2822
@pawel-big-lebowski
Extends the configurable integration test feature to enable getting the Docker image name as a name. - Spark: Support Iceberg 1.4 on Spark 3.5.1.
#2838
@pawel-big-lebowski
Include Iceberg support for Spark 3.5. Fix column level lineage facet forUNION
queries. - Spec: add example for change in
#2756
#2801
@Sheeri
Updates thecustomLineage
facet test for the new syntax created in#2756
.
- Spark: fallback to
spark.sql.warehouse.dir
as table namespace#2767
@dolfinus
In cases when a metastore is not used, falls back tospark.sql.warehouse.dir
orhive.metastore.warehouse.dir
as table namespace, instead of duplicating the table's location.
- Java: handle dashes in hostname for
JdbcExtractors
#2830
@dolfinus
Proper handling of dashes in JDBC URL hosts. - Spark: fix Glue symlinks formatting bug
#2807
@Akash2351
Fixes Glue symlinks with config parsing for Gluecatalogid
. - Spark, Flink: fix DBFS namespace format
#2800
@dolfinus
Fixes the DBFS namespace format. - Spark: fix Glue naming format
#2766
@dolfinus
Changes the AWS Glue namespace to match Glue ARN documentation. - Spark: fix Iceberg dataset location
#2797
@dolfinus
Fixes Iceberg dataset namespace: instead offile:/some/path/database.table
usesfile:/some/path/database/table
. For dataset TABLE symlink, uses warehouse location instead of database location. - Spark: fix NPE and incorrect comment
#2827
@pawel-big-lebowski
Fixes an error caused by a recent upgrade of Spark versions that did not break existing tests. - Spark: convert scheme and authority to lowercase in
JdbcLocation
#2831
@dolfinus
Converts valid JDBC URL scheme and authority to lowercase, leaving intact instance/database name, as different databases have different default case and case-sensitivity rules.
1.17.1 - 2024-06-21
- Java: dataset namespace resolver feature
#2720
@pawel-big-lebowski
Adds a dataset namespace resolving mechanism that resolves dataset namespaces based on the resolvers configured. The core mechanism is implemented in openlineage-java and can be used within the Flink and Spark integrations. - Spark: add transformation extraction
#2758
@tnazarew
Adds a transformation type extraction mechanism. - Spark: add GCP run and job facets
#2643
@codelixir
AddsGCPRunFacetBuilder
andGCPJobFacetBuilder
to report additional facets when running on Google Cloud Platform. - Spark: improve namespace format for SQLServer
#2773
@dolfinus
Improves the namespace format for SQLServer. - Spark: verify jar content after build
#2698
@pawel-big-lebowski
Adds a tool to verifyshadowJar
content and prevent reported issues. These are hard to prevent currently and require manual verification of manually unpacked jar content. - Spec: add transformation type info
#2756
@tnazarew
Adds information about the transformation type inColumnLineageDatasetFacet
.transformationType
andtransformationDescription
are marked as deprecated. - Spec: implementing facet registry (following #2161)
#2729
@harels
Introduces the foundations of the new facet Registry into the repo. - Spec: register GCP common job facet
#2740
@ngorchakova
Registers the GCP job facet that contains common attributes that will improve the way lineage is parsed and displayed by the GCP platform. Based on the proposal, GCP Lineage would like to define facets that are expected from integrations. The list of support facets is not final and will be extended further by next PR.
- Java: remove deprecated
localServerId
option from Kafka config#2738
@dolfinus
RemoveslocalServerId
from Kafka config, deprecated since 1.13.0. - Java: remove deprecated
Transport.emit(String)
#2737
@dolfinus
RemovesTransport.emit(String)
support, deprecated since 1.13.0. - Spark: remove
spark-interfaces-scala
module#2781
@ddebowczyk92
Replaces the existingspark-interfaces-scala
interfaces with new ones decoupled from the Scala binary version. Allows for improved integration in environments where one cannot guarantee the same version ofopenlineage-java
.
- Spark: add log info when emitting lineage from Spark (following #2650)
#2769
@algorithmy1
Enhances logging.
- Flink: use
namespace.name
as Avro complex field type#2763
@dolfinus
namespace.name
is now used as Avro"type"
of complex fields (record, enum, fixed). - Java: repair empty dataset name
#2776
@kacpermuda
The dataset name should not be empty. - Spark: fix events emitted for
drop table
for Spark 3.4 and above#2745
@pawel-big-lebowski@savannavalgi
Includes dataset being dropped within the event, as it used to be prior to Spark 3.4. - Spark, Flink: fix S3 dataset names
#2782
@dolfinus
Drops the leading slash from the object storage dataset name. Convertss3a://
ands3n://
schemes tos3://
. - Spark: fix Hive metastore namespace
#2761
@dolfinus
Fixes the dataset namespace for cases when the Hive metastore URL is set using$SPARK_CONF_DIR/hive-site.xml
. - Spark: fix NPE in column-level lineage
#2749
@pawel-big-lebowski
The Spark agent now checks to determine ifcur.getDependencies()
is not null before adding dependencies. - Spark: refactor
OpenLineageRunEventBuilder
#2754
@pawel-big-lebowski
Adds a separate class containing all the input arguments to callOpenLineageRunEventBuilder::buildRun
. - Spark: fix
historyUrl
format#2741
@dolfinus
Fixes thehistoryUrl
format inspark_applicationDetails
. - SQL: allow self-recursive aliases
#2753
@mobuchowski
Expressions likeselect * from test_orders as test_orders
are now parsed properly.
1.16.0 - 2024-05-28
- Spark: add
jobType
facet to Spark application events#2719
@dolfinus
AddjobType
facet torunEvent
s emitted bySparkListenerApplicationStart
. - Spark & Flink: Introduce dataset namespace resolver.
#2720
@pawel-big-lebowski
Enable resolving dataset namespace with predefined resolvers like:HostListNamespaceResolver
,PatternNamespaceResolver
,PatternMatchingGroupNamespaceResolver
or custom implementation loaded with ServiceLoader. Feature is useful to resolve hostnames into cluster identifiers.
- dbt: fix swapped namespace and name in dbt integration
#2735
@JDarDagran
Fixes variable names. - Python: override debug level
#2727
@mobuchowski
Removes debug-level logging of HTTP requests.
1.15.0 - 2024-05-23
- Flink: handle Iceberg tables with nested and complex field types
#2706
@dolfinus
CreatesSchemaDatasetFacet
with nested fields for Iceberg tables with list, map and struct columns. - Flink: handle Avro schema with nested and complex field types
#2711
@dolfinus
CreatesSchemaDatasetFacet
with nested fields for Avro schemas with complex types (union, record, map, array, fixed). - Spark: add facets to Spark application events
#2677
@dolfinus
Adds support for Spark application start and stop events in theExecutionContext
interface. - Spark: add nested fields to
SchemaDatasetFieldsFacet
#2689
@dolfinus
Adds nested Spark Dataframe fields support toSchemaDatasetFieldsFacet
. Also include field comment asdescription
. - Spark: add
SparkApplicationDetailsFacet
#2688
@dolfinus
AddsSparkApplicationDetailsFacet
torunEvent
s emitted on Spark application start.
- Airflow: remove Airflow < 2.3.0 support
#2710
@kacpermuda
Removes Airflow < 2.3.0 support. - Integration: use v2 Python facets
#2693
@JDarDagran
Migrates integrations from removed v1 facets to v2 Python facets.
- Spark: improve job suffix assigning mechanism
#2665
@pawel-big-lebowski
For some catalog handlers, the mechanism was creating different dataset identifiers on START and COMPLETE depending on whether a dataset was created or not. This improves the mechanism to assign a deterministic job suffix based on the output dataset at the moment of a start event. Note: this may change job names in some scenarios. - Airflow: fix empty dataset name for
AthenaExtractor
#2700
@kacpermuda
The dataset name should not be empty when passing only a bucket as S3 output in Athena. - Flink: fix
SchemaDatasetFacet
for Protobuf repeated primitive types#2685
@dolfinus
Fixes issues with the Protobuf schema converter. - Python: clean up Python client code, add logging.
#2653
@kacpermuda
Cleans up client code, refactors logging in all Python modules. - SQL: catch
TokenizerError
s,PanicException
#2703
@mobuchowski
The SQL parser now catches and handles these errors. - Python: suppress warning on importing v1 module in init.py.
#2713
@JDarDagran
Suppresses the deprecation warning when v1 facets are used. - Integration/Java/Python: use UUIDv7 instead of UUIDv4
#2686
#2687
@dolfinus
Uses UUIDv7 instead of UUIDv4 forrunEvent
s. The new UUID version produces monotonically increasing values, which leads to more performant queries on the OL consumer side. Note: UUID version is an implementation detail and can be changed in the future.
1.14.0 - 2024-05-09
- Common/dbt: add DREMIO to supported dbt profile types
#2674
@surisimran
*Adds support for dbt-dremio, resolving#2668
. - Flink: support Protobuf format for sources and sinks
#2482
@pawel-big-lebowski
Adds schema extraction from Protobuf classes. Includes support for nested object types,array
type,map
type,oneOf
andany
. - Java: add facet conversion test
#2663
@julienledem
Adds a simple test that shows how to deserialize a facet in the server model. - Spark: job type facet to distinguish RDD jobs from Spark SQL jobs
#2652
@pawel-big-lebowski
Sets thejobType
property ofJobTypeJobFacet
to eitherSQL_JOB
orRDD_JOB
. - Spark: add Glue symlink if reading from Glue catalog table
#2646
@mobuchowski
The dataset symlink now points to the Glue catalog table name if the Glue catalog table is used. - Spark: add
spark_jobDetails
facet#2662
@dolfinus
Adds aSparkJobDetailsFacet
, capturing information about Spark application jobs -- e.g.jobId
,jobDescription
,jobGroup
,jobCallSite
. This allows for tracking an OpenLineageRunEvent
with a specific Spark job in SparkUI.
- Airflow: drop old
ParentRunFacet
key#2660
@dolfinus
Changes the integration to use theparent
key forParentFacet
, dropping the outdatedparentRun
. - Spark: drop
SparkVersionFacet
#2659
@dolfinus
Drops theSparkVersion
facet, deprecated since 1.2.0 and planned for removal since 1.4.0. - Python: allow relative paths in URI formats for Python facets
#2679
@JDarDagran
Removes a URI validator that checked if scheme and netloc were present, allowing relative paths in URI formats for Python facets.
- GreatExpectations: rename
ParentRunFacet
key#2661
@dolfinus
The OpenLineage spec defined theParentRunFacet
with the property name parent but the Great Expectations integration created a lineage event withparentRun
. This renamesParentRunFacet
key fromparentRun
toparent
. For backwards compatibility, keep the old name.
- dbt: support a less ambiguous logic to generate job names
#2658
@blacklight
Includes profile and models in the dbt job name to make it more unique. - Spark: update to use
org.apache.commons.lang3
instead oforg.apache.commons.lang
#2676
@harels
Updates Apache Commons Lang to the latest version. We were mixing two versions, and the old one was not present in many places.
1.13.1 - 2024-04-25
- Java: allow timeout for circuit breakers
#2609
@pawel-big-lebowski@athityakumar
Extends the circuit breaker mechanism to contain a global timeout that stops running OpenLineage integration code when a specified amount of time has elapsed. - Java: handle
DataSetEvent
andJobEvent
inTransport.emit
#2611
@dolfinus
Adds overloadsTransport.emit(OpenLineage.DatasetEvent)
andTransport.emit(OpenLineage.JobEvent)
, reusing the implementation ofTransport.emit(OpenLineage.RunEvent)
. Please note:Transport.emit(String)
is now deprecated and will be removed in 1.16.0. - Java/Python: add
GZIP
compression toHttpTransport
#2603
#2604
@dolfinus
Adds acompression
option toHttpTransport
config in the Java and Python clients, withgzip
implementation. - Java/Python/Proxy: properly set Kafka message key
#2571
#2597
#2598
@dolfinus
Adds a newmessageKey
option toKafkaTransport
config in the Python and Java clients, as well as the Proxy. This option replaces thelocalServerId
option, which is now deprecated. Default value is generated using the run id (forRunEvent
), job name (forJobEvent
) or dataset name (forDatasetEvent
). This value is used by the Kafka producer to distribute messages along topic partitions, instead of sending all the events to the same partition. This allows for full utilization of Kafka performance advantages. - Flink: add support for Micrometer metrics
#2633
@mobuchowski
Adds a mechanism for forwarding metrics to any Micrometer-compatible implementation for Flink as has been implemented for Spark. Included:MeterRegistry
,CompositeMeterRegistry
,SimpleMeterRegistry
, andMicrometerProvider
. - Python: generate Python facets from JSON schemas
#2520
@JDarDagran
Objects specified with JSON Schema needed to be manually developed and checked in Python, leading to many discrepancies, including wrong schema URLs. This adds adatamodel-code-generator
for parsing JSON Schema and generating Pydantic or dataclasses classes, etc. In order to useattrs
(a more modern version of dataclasses) and overcome some limitations of the tool, a number of steps have been added in order to customize code to meet OpenLineage requirements. Included: updated references to the latest base JSON Schema spec for all child facets. Please note: newly generated code creates a v2 interface that will be implemented in existing integrations in a future release. The v2 interface introduces some breaking changes: facets are put into separate modules per JSON Schema spec file, some names are changed, and several classes are nowkw_only
. - Spark/Flink/Java: support YAML config files together with SparkConf/FlinkConf
#2583
@pawel-big-lebowski
Creates aSparkOpenlineageConfig
andFlinkOpenlineageConfig
for a more uniform configuration experience for the user. RenamesOpenLineageYaml
toOpenLineageConfig
and modifies the code to use onlyOpenLineageConfig
classes. Includes a doc update to mention that both ways can be used interchangeably and final documentation will merge all values provided. - Spark: add custom token provider support
#2613
@tnazarew
Adds aTokenProviderTypeIdResolver
to handle bothFQCN
and (for backward compatibility)api_key
types inspark.openlineage.transport.auth.type
. - Spark/Flink: job ownership facet
#2533
@pawel-big-lebowski
Enables configuration entries specifying ownership of the job that will result in anOwnershipJobFacet
being attached to job facets.
- Java: sync Kinesis
partitionKey
format with Kafka implementation#2620
@dolfinus
Changes the format of KinesispartitionKey
from{jobNamespace}:{jobName}
torun:{jobNamespace}/{jobName}
to match the Kafka transport implementation.
- Python: make
load_config
return an empty dict instead ofNone
when file empty#2596
@kacpermuda
utils.load_config()
now returns an empty dict instead ofNone
in the case of an empty file to prevent anOpenLineageClient
crash. - Java: render lombok-generated methods in javadoc
#2614
@dolfinus
Fixes rendering of javadoc for methods generated bylombok
annotations by adding adelombok
step. - Spark/Snowflake: parse NPE when query option is used and table is empty
#2599
@mobuchowski
Fixes NPE when using query option when reading from Snowflake.
1.12.0 - 2024-04-09
- Airflow: add
lineage_job_namespace
andlineage_job_name
macros#2582
@dolfinus Adds new Airflow macroslineage_job_namespace()
,lineage_job_name(task)
that return an Airflow namespace and Airflow job name, respectively. - Spec: allow nested struct fields in
SchemaDatasetFacet
#2548
@dolfinus Allows nested fields support toSchemaDatasetFacet
.
- Airflow: fix format returned by
airflow.macros.lineage_parent_id
#2578
@blacklight
Fixes the run format returned by thelineage_parent_id
Airflow macro and simplifies the format of thelineage_parent_id
andlineage_run_id
macros. - Dbt: propagate the dbt return code also when no OpenLineage events are emitted
#2591
@blacklight
dbt-ol
now propagates the exit code of the underlying dbt process even if no lineage events are emitted. - Dagster: limit Dagster version to 1.6.9
#2579
@JDarDagran
Adds an upper limit on supported versions of Dagster as the integration is no longer actively maintained and recent releases introduce breaking changes. - Java: make sure string isn't empty to prevent going out of bounds
#2585
@harels
String lookup was not accounting for empty strings and causing ajava.lang.StringIndexOutOfBoundsException
. - Java: fix javadoc
#2624
@pawel-big-lebowski
Improves developer experience by fixing issues resulting in warnings on build. - Python: fix missing
pkg_resources
module on Python 3.12#2572
@dolfinus
Removespkg_resources
dependency and replaces it with the packaging lib. - Spark: use
HashSet
in column-level lineage instead of iterating throughLinkedList
#2584
@mobuchowski
Takes advantage of performance gains available from usingHashSet
for collection.
1.11.3 - 2024-04-04
- Common: add support for
SCRIPT
-type jobs in BigQuery#2564
@kacpermuda
In the case ofSCRIPT
-type jobs in BigQuery, no lineage was being extracted because theSCRIPT
job had no lineage information - it only spawned child jobs that had that information. With this change, the integration extracts lineage information from child jobs when dealing withSCRIPT
-type jobs. - Spark: support for built-in lineage extraction
#2272
@pawel-big-lebowski
This PR adds aspark-interfaces-scala
package that allows lineage extraction to be implemented within Spark extensions (Iceberg, Delta, GCS, etc.). The Openlineage integration, when traversing the query plan, verifies if nodes implement defined interfaces. If so, interface methods are used to extract lineage. Refer to the README for more details. - Spark/Java: add support for Micrometer metrics
#2496
@mobuchowski
Adds a mechanism for forwarding metrics to any Micrometer-compatible implementation. Included:MeterRegistryFactory
,MicrometerProvider
,StatsDMetricsBuilder
, metrics config in OpenLineage config, and a Java client implementation. - Spark: add support for telemetry mechanism
#2528
@mobuchowski
Adds timers, counters and additional instrumentation in order to implement Micrometer metrics collection. - Spark: support query option on table read
#2556
@mobuchowski
Adds support for the Spark-BigQuery connector's query input option, which executes a query directly on BigQuery, storing the result in an intermediate dataset, bypassing Spark's computation layer. Due to this, the lineage is retrieved using the SQL parser, similarly toJDBCRelation
. - Spark: change
SparkPropertyFacetBuilder
to support recording Spark runtime#2523
@Ruihua98
ModifiesSparkPropertyFacetBuilder
to capture theRuntimeConfig
of the Spark session because the existingSparkPropertyFacet
can only capture the static config of the Spark context. This facet will be added in both RDD-related and SQL-related runs. - Spec: add
fileCount
to dataset stat facets#2562
@dolfinus
Adds afileCount
field toDataQualityMetricsInputDatasetFacet
andOutputStatisticsOutputDatasetFacet
specification.
- dbt:
dbt-ol
should transparently exit with the same exit code as the childdbt
process#2560
@blacklight
Makesdbt-ol
transparently exit with the same exit code as the childdbt
process. - Flink: disable module metadata generation
#2531
@HuangZhenQiu
Disables the module metadata generation for Flink to fix the problem of having gradle dependencies to submodules withinopenlineage-flink.jar
. - Flink: fixes to version 1.19
#2507
@pawel-big-lebowski
Fixes the class not found issue when checking for Cassandra classes. Also fixes the Maven pom dependency on subprojects. - Python: small improvements to
.emit()
method logging & annotations#2539
@dolfinus
Updates OpenLineage.emit debug messages and annotations. - SQL: show error message when OpenLineageSql cannot find native library
#2547
@dolfinus
When theOpenLineageSql
class could not load a native library, if returnedNone
for all operations. But because the error message was suppressed, the user could not determine the reason. - SQL: update code to conform to upstream sqlparser-rs changes
#2510
@mobuchowski
Includes tests and cosmetic improvements. - Spark: fix access to active Spark session
#2535
@pawel-big-lebowski
Changes behavior soIllegalStateException
is always caught when accessingSparkSession
. - Spark: fix Databricks environment
#2537
@pawel-big-lebowski
Fixes theClassNotFoundError
occurring on Databricks runtime and extends the integration test to verifyDatabricksEnvironmentFacet
. - Spark: fixed memory leak in JobMetricsHolder
#2565
@d-m-h TheJobMetricsHolder#cleanUp(int)
method now correctly purges unneeded state from both maps. - Spark: fixed memory leak in
UnknownEntryFacetListener
#2557
@pawel-big-lebowski Prevents storing the state when a facet is disabled, purging the state after populating run facets. - Spark: fix parsing
JDBCOptions(table=...)
containing subquery#2546
@dolfinus
Preventsopenlineage-spark
from producing datasets with names likedatabase.(select * from table)
for JDBC sources. - Spark/Snowflake: support query option via SQL parser
#2563
@mobuchowski
When a Snowflake job is bypassing Spark's computation layer, now the SQL parser will be used to get the lineage. - Spark: always catch
IllegalStateException
when accessingSparkSession
#2535
@pawel-big-lebowski
IllegalStateException
was not being caught.
1.10.2 - 2024-03-15
- Dagster: add new provider for version 1.6.10
#2518
@JDarDagran
Adds the new provider required by the latest version of Dagster. - Flink: support lineage for a hybrid source
#2491
@HuangZhenQiu
Adds support for hybrid source lineage for users of Kafka and Iceberg sources in backfill usecases. - Flink: improve Cassandra lineage metadata
#2479
@HuangZhenQiu
Cassandra cluster info to be used as the dataset namespace, and the keyspace to be combined with the table name as the dataset name. - Flink: bump Flink JDBC connector version
#2472
@HuangZhenQiu
Bumps the Flink JDBC connector version to 3.1.2-1.18 for Flink 1.18. - Java: add a
OpenLineageClientUtils#loadOpenLineageJson(InputStream)
and changeOpenLineageClientUtils#loadOpenLineageYaml(InputStream)
methods#2490
@d-m-h
This improves the explicitness of the methods. Previously,loadOpenLineageYaml(InputStream)
wanted theInputStream
to contain bytes that represented JSON. - Java: add info from the HTTP response to the client exception
#2486
@davidjgoss
Adds the status code and body as properties on the thrown exception when a non-success response is encountered in the HTTP transport. - Python: add support for MSK IAM authentication with a new transport
#2478
@mattiabertorello
Eases publication of events to MSK with IAM authentication.
- Airflow: remove redundant information from facets
#2524
@kacpermuda
Refines the operator's attribute inclusion logic in facets to include only those known to be important or compact, ensuring that custom operator attributes with substantial data do not inflate the event size.
- Airflow: proceed without rendering templates if
task_instance
copy fails#2492
@kacpermuda
Airflow will now proceed without rendering templates iftask_instance
copy fails inlistener.on_task_instance_running
. - Spark: fix the
HttpTransport
timeout#2475
@pawel-big-lebowski
The existingtimeout
config parameter is ambiguous: implementation treats the value as double in seconds, although the documentation claims it's milliseconds. A new config paramtimeoutInMillis
has been added. the Existingtimeout
has been removed from docs and will be deprecated in 1.13. - Spark: prevent NPE if the context is null
#2515
@pawel-big-lebowski
Adds a check for a null context before executingend(jobEnd)
. - Flink: fix class not found issue for Cassandra
#2507
@pawel-big-lebowski
Fixes the class not found issue when checking for Cassandra classes. Also fixes the Maven POM dependency on subprojects. - Flink: refine the JDBC table name
#2512
@HuangZhenQiu
Enables the JDBC table name with a schema prefix. - Flink: fix JDBC dataset naming
#2508
@pawel-big-lebowski
For JDBC, the Flink integration is not adjusted to the Openlineage naming convention. There is code that extracts the dataset namespace/name from the JDBC connection url, but it's in the Spark integration. As a solution, this code has to be extracted into the Java client and reused by the Spark and Flink integrations. - Flink: fix failure due to missing Cassandra classes
#2507
@pawel-big-lebowski
Flink is failing when no Cassandra classes are present on the class path. This is happening because ofCassandraUtils
class which has a statichasClasses
method, but it imports Cassandra-related classes in the header. Also, the Flink subproject contains an unnecessarymaven-publish
plugin. - Flink: fix release runtime dependencies
#2504
@HuangZhenQiu
The shadow jar of Flink is not minimized, so some internal jars are listed as runtime dependences. This removes them from the final pom.xml file in the Flink module. - Spec: improve Cassandra lineage metadata
#2479
@HuangZhenQiu
Following the namespace definition, we should usecassandra://host:port
.
1.9.1 - 2024-02-26
- Airflow: add support for
JobTypeJobFacet
properties#2412
@mattiabertorello
Adds support for Job type properties within the Airflow Job facet. - dbt: add support for
JobTypeJobFacet
properties#2411
@mattiabertorello
Support Job type properties within the DBT Job facet. - Flink: support Flink Kafka dynamic source and sink (OpenLineage#2417) @HuangZhenQiu
Adds support for Flink Kafka Table Connector use cases for topic and schema extraction. - Flink: support multi-topic Kafka Sink
#2372
@pawel-big-lebowski
Adds support for multi-topic Kafka sinks. Limitations:recordSerializer
needs to implementKafkaTopicsDescriptor
. Please refer to the limitations sections in documentation. - Flink: support lineage for JDBC connector
#2436
@HuangZhenQiu
Adds support for use cases that employ this connector. - Flink: add common config gradle plugin (OpenLineage#2461) @HuangZhenQiu
Add common config gradle plugin to simplify gradle files of Flink submodules. - Java: extend circuit breaker loaded with
ServiceLoader
#2435
@pawel-big-lebowski
Loads the circuit breaker builder withServiceLoader
as an addition to a list of implemented builders available within the existing package. - Spark: integration now emits intermediate, application level events wrapping entire job execution
#2371
@mobuchowski
Previously, the Spark event model described only single actions, potentially linked only to some parent run. Closes#1672
. - Spark: support built-in lineage within
DataSourceV2Relation
#2394
@pawel-big-lebowski
Enables built-in lineage extraction within fromDataSourceV2Relation
lineage nodes. - Spark: add support for
JobTypeJobFacet
properties#2410
@mattiabertorello
Adds support for Job type properties within the Spark Job facet. - Spark: stop sending
spark.LogicalPlan
facet by default#2433
@pawel-big-lebowski
spark.LogicalPlan
has been added to default value ofspark.openlineage.facets.disabled
. - Spark/Flink/Java: circuit breaker
#2407
@pawel-big-lebowski
Introduces a circuit breaker mechanism to prevent effects of over-instrumentation. Implemented within Java client, it serves both the Flink and Spark integration. Read the Java client README for more details. - Spark: add the capability to publish Scala 2.12 and 2.13 variants of
openlineage-spark
#2446
@d-m-h
Adds the capability to publish Scala 2.12 and 2.13 variants ofopenlineage-spark
- Spark: enable the
app
module to be compiled with Scala 2.12 and Scala 2.13 variants of Apache Spark (OpenLineage#2432) @d-m-h
Thespark.binary.version
andspark.version
properties control which variant to build. - Spark: enable Scala 2.13 support in the
app
module#2432
@d-m-h
Enables theapp
module to be built using both Scala 2.12 and Scala 2.13 variants of various Apache Spark versions, and enables the CI/CD pipeline to build and test them. - Spark: don't fail on exception of
UnknownEntryFacet
creation#2431
@mobuchowski
Failure to generateUnknownEntryFacet
was resulting in the event not being sent. - Spark: move Snowflake code into the vendor projects folders
#2405
@mattiabertorello
Creates avendor
folder to isolate Snowflake-specific code from the main Spark integration, enhancing organization and flexibility.
- Flink: resolve PMD rule violation warnings
#2403
@HuangZhenQiu
Resolves the PMD rule violation warnings in the Flink integration module. - Flink: Added the 'isReleaseVersion' property back to the build, enabling the Flink integration to be release
#2468
@d-m-h
The 'isReleaseVersion' property was removed from the build, preventing the Flink integration from being released. - Python: fix issue with file config creating additional file
#2447
@kacpermuda
FileConfig
was creating an additional file when not in append mode. Closes#2439
. - Python: fix issue with append option in file config
#2441
@kacpermuda
FileConfig
was ignoring the append key in YAML config. Closes#2440
- Spark: fix integration catalog symlink without warehouse
#2379
@algorithmy1
In the case of symlinked Glue Catalog Tables, the parsing method was producing dataset names identical to the namespace. - Flink: fix
IcebergSourceWrapper
for Iceberg connector 1.17#2409
@ensctom
In Flink 1.17, the Icebergcatalogloader
was loading the catalog in the open function, causing theloadTable
method to throw aNullPointerException
error. - Spark: migrate
spark35
,spark3
,shared
modules to produce Scala 2.12 and Scala 2.13 variants#2390
#2385
#2384
@d-m-h
Migrates the three modules to use the refactored Gradle plugins. Also splits some tests into Scala 2.12- and Scala 2.13-specific versions. - Spark: conform the
spark2
module to the new build process#2391
@d-m-h
Due to a change in the Scala Collections API in Scala 2.13,NoSuchMethodErrors
were being thrown when running the openlineage-spack connector in an Apache Spark runtime compiled using Scala 2.13.
1.8.0 - 2024-01-19
- Flink: support Flink 1.18
#2366
@HuangZhenQiu
Adds support for the latest Flink version with 1.17 used for Iceberg Flink runtime and Cassandra Connector as these do not yet support 1.18. - Spark: add Gradle plugins to simplify the build process to support Scala 2.13
#2376
@d-m-h
*Defines a set of Gradle plugins to configure the modules and reduce duplication. - Spark: support multiple Scala versions
LogicalPlan
implementation#2361
@mattiabertorello
In the LogicalPlanSerializerTest class, the implementation of the LogicalPlan interface is different between Scala 2.12 and Scala 2.13. In detail, the IndexedSeq changes package from the scala.collection to scala.collection.immutable. This implements both of the methods necessary in the two versions. - Spark: Use ScalaConversionUtils to convert Scala and Java collections
#2357
@mattiabertorello
This initial step is to start supporting compilation for Scala 2.13 in the 3.2+ Spark versions. Scala 2.13 changed the default collection to immutable, the methods to create an empty collection, and the conversion between Java and Scala. This causes the code to not compile between 2.12 and 2.13. This replaces the usage of direct Scala collection methods (like creating an empty object) and conversions utils withScalaConversionUtils
methods that will support cross-compilation. - Spark: support
MERGE INTO
queries on Databricks#2348
@pawel-big-lebowski
Supports custom plan nodes used when runningMERGE INTO
queries on Databricks runtime. - Spark: Support Glue catalog in iceberg
#2283
@nataliezeller1
Adds support for the Glue catalog based on the 'catalog-impl' property (in this case we will not have a 'type' property).
- Spark: Move Spark 3.1 code from the spark3 project
#2365
@mattiabertorello
Moves the Spark 3.1-related code to a specific project, spark31, so the spark3 project can be compiled with any Spark 3.x version.
- Airflow: add database information to SnowflakeExtractor
#2364
@kacpermuda
Fixes missing database information in SnowflakeExtractor. - Airflow: add dag_id to task_run_id to avoid duplicates
#2358
@kacpermuda
The lack of dag_id in task_run_id can cause duplicates in run_id across different dags. - Airflow: Add tests for column lineage facet and sql parser
#2373
@kacpermuda
Improves naming (database.schema.table) in SQLExtractor's column lineage facet and adds some unit tests. - Spark: fix removePathPattern behaviour
#2350
@pawel-big-lebowski
The removepath pattern feature is not applied all the time. The method is called when constructing DatasetIdentifier through PathUtils which is not the case all the time. This moves removePattern to another place in the codebase that is always run. - Spark: fix a type incompatibility in RddExecutionContext between Scala 2.12 and 2.13
#2360
@mattiabertorello
The function from the ResultStage.func() object change type in Spark between Scala 2.12 and 2.13 makes the compilation fail. This avoids getting the function with an explicit type; instead, it gets it every time it is needed from the ResultStage object. This PR is part of the effort to support Scala 2.13 in the Spark integration. - Spark: Fix
removePathPattern
feature#2350
@pawel-big-lebowski
Refactors code to make sure that all datasets sent are processed throughremovePathPattern
if configured to do so. - Spark: Clean up the individual build.gradle files in preparation for Scala 2.13 support
#2377
@d-m-h
Cleans up the build.gradle files, consolidating the custom plugin and removing unused and unnecessary configuration. - Spark: refactor the Gradle plugins to make it easier to define Scala variants per module
#2383
@d-m-h
The third of several PRs to support producing Scala 2.12 and Scala 2.13 variants of the OpenLineage Spark integration. This PR refactors the custom Gradle plugins in order to make supporting multiple variants per module easier. This is necessary because the shared module fails its tests when consuming the Scala 2.13 variants of Apache Spark.
1.7.0 - 2023-12-21
- 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.
- 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
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.
- Airflow: remove Airflow 2.8+ support
#2330
@kacpermuda
To encourage use of the Provider, this removes the listener from the plugin if the Airflow version is<2.3.0
or>=2.8.0
.
1.6.2 - 2023-12-07
- Dagster: support Dagster 1.5.x
#2220
@tsungchih
Gets event records for each target Dagster event type to support Dagster version 0.15.0+. - Dbt: add a new command
dbt-ol send-events
to send metadata of the last run without running the job#2285
@sophiely
Adds a new command to send events to OpenLineage according to the latest metadata generated without running any dbt command. - Flink: add option for Flink job listener to read from Flink conf
#2229
@ensctom
Adds option for the Flink job listener to read jobnames and namespaces from Flink conf. - Spark: get column-level lineage from JDBC dbtable option
#2284
@mobuchowski
Adds support for dbtable, enables lineage in the case of single input columns, and improves dataset naming. - Spec: introduce
JobTypeJobFacet
to contain additional job related information#2241
@pawel-big-lebowski
NewJobTypeJobFacet
contains the processing type such asBATCH|STREAMING
, integration viaSPARK|FLINK|...
and job type inQUERY|COMMAND|DAG|...
. - SQL: add quote information from sqlparser-rs
#2259
@JDarDagran
Adds quote information from sqlparser-rs.
- Spark: update Jackson dependency to resolve
CVE-2022-1471
#2185
@pawel-big-lebowski
Updates Gradle for Spark and Flink to 8.1.1. Upgrade Jackson2.15.3
. - Flink: avoid relying on Guava which can be missing during production runtime
#2296
@pawel-big-lebowski
Removes usage of Guava ImmutableList. - Spark: exclude
commons-logging
transitive dependency from published jar#2297
@pawel-big-lebowski
Ensurescommons-logging
is not shipped as this can lead to a version mismatch on the user's side.
1.5.0 - 2023-11-01
- Flink: add Flink lineage for Cassandra Connectors
#2175
@HuangZhenQiu
Adds Flink Cassandra source and sink visitors and Flink Cassandra Integration test. - Spark: support
rdd
andtoDF
operations available in Spark Scala API#2188
@pawel-big-lebowski
Includes the first Scala integration test, fixesExternalRddVisitor
and adds support for extracting inputs fromMapPartitionsRDD
andParallelCollectionRDD
plan nodes. - Spark: support Databricks Runtime 13.3
#2185
@pawel-big-lebowski
Modifies the Spark integration to support the latest Databricks Runtime version.
- Airflow: loosen attrs and requests versions
#2107
@JDarDagran
Lowers the version requirements for attrs and requests and removes an unnecessary dependency. - dbt: render yaml configs lazily
#2221
@JDarDagran
Don't render each entry in yaml files at start.
- Airflow/Athena: change dataset name to its location
#2167
@sophiely
Replaces the dataset and namespace with the data's physical location for more complete lineage across integrations. - Python client: skip redaction in column lineage facet
#2177
@JDarDagran
Redacted fields inColumnLineageDatasetFacetFieldsAdditionalInputFields
are now skipped. - Spark: unify dataset naming for RDD jobs and Spark SQL
#2181
@pawel-big-lebowski
Use the same mechanism for RDD jobs to extract dataset identifier as used for Spark SQL. - Spark: ensure a single
START
and a singleCOMPLETE
event are sent#2103
@pawel-big-lebowski
For Spark SQL at least four events are sent triggered by different SparkListener methods. Each of them is required and used to collect facets unavailable elsewhere. However, there should be only oneSTART
andCOMPLETE
events emitted. Other events should be sent asRUNNING
. Please keep in mind that Spark integration remains stateless to limit the memory footprint, and it is the backend responsibility to merge several Openlineage events into a meaningful snapshot of metadata changes.
1.4.1 - 2023-10-09
- Client: allow setting client's endpoint via environment variable
#2151
@mars-lan
Enables setting this endpoint via environment variable because creating the client manually in Airflow is not possible. - Flink: expand Iceberg source types
#2149
@HuangZhenQiu
Adds support forFlinkIcebergSource
andFlinkIcebergTableSource
for Flink Iceberg lineage. - Spark: add debug facet
#2147
@pawel-big-lebowski
An extra run facet containing some system details (e.g., OS, Java, Scala version), classpath (e.g., package versions, jars included in the Spark job), SparkConf (like openlineage entries except auth, specified extensions, etc.) and LogicalPlan details (execution tree nodes' names) are added to events emitted. SparkConf settingspark.openlineage.debugFacet=enabled
needs to be set to include the facet. By default, the debug facet is disabled. - Spark: enable Nessie REST catalog
#2165
@julwin
Adds support for Nessie catalog in Spark.
1.3.1 - 2023-10-03
- Airflow: add some basic stats to the Airflow integration
#1845
@harels
Uses the statsd component that already exists in the Airflow codebase and wraps the section that emits to event with a timer, as well as emitting a counter for exceptions in sending the event. - Airflow: add columns as schema facet for
airflow.lineage.Table
(if defined)#2138
@erikalfthan
Adds columns (if set) fromairflow.lineage.Table
inlets/outlets to the OpenLineage Dataset. - dbt: add SQLSERVER to supported dbt profile types
#2136
@erikalfthan
Adds support for dbt-sqlserver, solving #2129. - Spark: support for latest 3.5
2118
@pawel-big-lebowski
Integration tests are now run on Spark 3.5. Also upgrades 3.3 branch to 3.3.3. Please note thatdelta
andiceberg
are not supported for Spark3.5
at this time. - Flink: expand iceberge source types
#2149
@HuangZhenQiu Add Iceberg Source and Iceberg Table Source for Flink Lineage.
- Airflow: fix find-links path in tox
#2139
@JDarDagran
Fixes a broken link. - Airflow: add more graceful logging when no OpenLineage provider installed
#2141
@JDarDagran
Recognizes a failed import ofairflow.providers.openlineage
and adds more graceful logging to fix a corner case. - Spark: fix bug in PathUtils' prepareDatasetIdentifierFromDefaultTablePath(CatalogTable) to correctly preserve scheme from CatalogTable's location
#2142
@d-m-h
Previously, the prepareDatasetIdentifierFromDefaultTablePath method would override the scheme with the value of "file" when constructing a dataset identifier. It now uses the scheme of the CatalogTable's URI for this. Thank you @pawel-big-lebowski for the quick triage and suggested fix.
1.2.2 - 2023-09-19
- Spark: publish the
ProcessingEngineRunFacet
as part of the normal operation of theOpenLineageSparkEventListener
#2089
@d-m-h
Publishes the spec-definedProcessEngineRunFacet
alongside the customSparkVersionFacet
(for now). TheSparkVersionFacet
is deprecated and will be removed in a future release. - Spark: capture and emit
spark.databricks.clusterUsageTags.clusterAllTags
variable from databricks environment#2099
@Anirudh181001
Addsspark.databricks.clusterUsageTags.clusterAllTags
to the list of environment variables captured from databricks.
- Common: support parsing dbt_project.yml without target-path
#2106
@tatiana
As of dbt v1.5, usage of target-path in the dbt_project.yml file has been deprecated, now preferring a CLI flag or env var. It will be removed in a future version. This allows users to runDbtLocalArtifactProcessor
in dbt projects that do not declare target-path. - Proxy: fix Proxy chart
#2091
@harels
Includes the proper image to deploy in the helm chart. - Python: fix serde filtering
#2044
@xli-1026
Fixes the bug causing values in list objects to be filtered accidentally. - Python: use non-deprecated
apiKey
if loading it from env variables#2029
@mobuchowski
Changesapi_key
toapiKey
increate_token_provider
. - Spark: Improve RDDs on S3 integration.
#2039
@pawel-big-lebowski
Prepares integration test to access S3, fixes input dataset duplicates and includes other minor fixes. - Flink: prevent sending
running
events after job completes#2075
@pawel-big-lebowski
Flink checkpoint tracking thread was not getting stopped properly on job complete. - Spark & Flink: Unify dataset naming from URI objects
#2083
@pawel-big-lebowski
Makes sure Spark and Flink generate same dataset identifiers for the same datasets by having a single implementation to generate dataset namespace and name. - Spark: Databricks improvements
#2076
@pawel-big-lebowski
Filters unwanted events on databricks and adds an integration test to verify this. Adds integration tests to verify dataset naming on databricks runtime is correct when table location is specified. Adds integration test for wide transformation on delta tables.
- SQL: remove sqlparser dependency from iface-java and iface-py
#2090
@JDarDagran
Removes the dependency due to a breaking change in the latest release of the parser.
1.1.0 - 2023-08-23
- Flink: create Openlineage configuration based on Flink configuration
#2033
@pawel-big-lebowski
Flink configuration entries starting withopenlineage.*
are passed to the Openlineage client. - Java: add Javadocs to the Java client
#2004
@julienledem
The client was missing some Javadocs. - Spark: append output dataset name to a job name
#2036
@pawel-big-lebowski
Solves problem of multiple jobs, writing to different datasets while having the same job name. The feature is enabled by default and results in different job names and can be disabled by settingspark.openlineage.jobName.appendDatasetName
tofalse
. Unifies job names generated on the Databricks platform (using a dot job part separator instead of an underscore). The default behaviour can be altered withspark.openlineage.jobName.replaceDotWithUnderscore
. - Spark: support Spark 3.4.1
#2057
@pawel-big-lebowski
Bumps the latest Spark version to be covered in integration tests.
- Airflow: do not use database as fallback when no schema parsed
#2023
@mobuchowski
Sets the schema toNone
inTablesHierarchy
to skip filtering on the schema level in the information schema query. - Flink: fix a bug when getting schema for
KafkaSink
#2042
@pentium3
Fixes the incomplete schema fromKafkaSinkVisitor
by changing theKafkaSinkWrapper
to catch schemas of typeAvroSerializationSchema
. - Spark: filter
CreateView
events#1968
#1987
@pawel-big-lebowski
Clears events generated by logical plans havingCreateView
nodes as root. - Spark: fix
MERGE INTO
for delta tables identified by physical locations#2026
Delta tables identified by physical locations were not properly recognized. - Spark: fix incorrect naming of JDBC datasets
#2035
@mobuchowski
Makes the namespace generated by the JDBC/Spark connector conform to the naming schema in the spec. - Spark: fix ignored event
adaptive_spark_plan
in Databricks#2061
@algorithmy1
Removesadaptive_spark_plan
from theexcludedNodes
inDatabricksEventFilter
.
1.0.0 - 2023-08-01
- Airflow: convert lineage from legacy
File
definition#2006
@mobuchowski
Adds coverage forFile
entity definition to enhance backwards compatibility.
- Spec: remove facet ref from core
#1997
@JDarDagran
Removes references to facets from the core spec that broke compatibility with JSON schema specification.
- Airflow: change log level to
DEBUG
when extractor isn't found#2012
@kaxil
Changes log level fromWARNING
toDEBUG
when an extractor is not available. - Airflow: make sure we cannot fail in thread despite direct execution
#2010
@mobuchowski
Ensures the listener is not failing tasks, even in unlikely scenarios.
- Airflow: stop using reusable session by default, do not send full event on Snowflake complete
#2025
@mobuchowski
Fixes the issue of the Snowflake connector clashing withHttpTransport
by disabling automaticrequests
session reuse and not runningSnowflakeExtractor
again on job completion. - Client: fix error message to avoid confusion
#2001
@mars-lan
Fixes the error message inHttpTransport
in the case of a null URL.
0.30.1 - 2023-07-25
- Flink: support Iceberg sinks
#1960
@pawel-big-lebowski
Detects output datasets when using an Iceberg table as a sink. - Spark: column-level lineage for
merge into
on delta tables#1958
@pawel-big-lebowski
Makes column-level lineage supportmerge into
on Delta tables. Also refactors column-level lineage to deal with multiple Spark versions. - Spark: column-level lineage for
merge into
on Iceberg tables#1971
@pawel-big-lebowski
Makes column-level lineage supportmerge into
on Iceberg tables. - Spark: add support for Iceberg REST catalog
#1963
@juancappi
Addsrest
to the existing options ofhive
andhadoop
inIcebergHandler.getDatasetIdentifier()
to add support for Iceberg'sRestCatalog
. - Airflow: add possibility to force direct-execution based on environment variable
#1934
@mobuchowski
Adds the option to use the direct-execution method on the Airflow listener when the existence of a non-SQLAlchemy-based Airflow event mechanism is confirmed. This happens when using Airflow 2.6 or when theOPENLINEAGE_AIRFLOW_ENABLE_DIRECT_EXECUTION
environment variable exists. - SQL: add support for Apple Silicon to
openlineage-sql-java
#1981
@davidjgoss
Expands the OS/architecture checks when compiling to produce a specific file for Apple Silicon. Also expands the corresponding OS/architecture checks when loading the binary at runtime from Java code. - Spec: add facet deletion
#1975
@julienledem
In order to add a mechanism for deleting job and dataset facets, adds a{ _deleted: true }
object that can take the place of any job or dataset facet (but not run or input/output facets, which are valid only for a specific run). - Client: add a file transport
#1891
@Alexkuva
Creates aFileTransport
and its configuration classes supporting append mode or write-new-file mode, which is especially useful when an object store does not support append mode, e.g. in the case of Databricks DBFS FUSE.
- Airflow: do not run plugin if OpenLineage provider is installed
#1999
@JDarDagran
SetsOPENLINEAGE_DISABLED
totrue
if the provider is installed. - Python: rename
config
toconfig_class
#1998
@mobuchowski
Renames theconfig
class variable toconfig_class
to avoid potential conflict with the config instance.
- Airflow: add workaround for airflow-sqlalchemy event mechanism bug
#1959
@mobuchowski
Due to known issues with the fork and thread model in the Airflow-SQLAlchemy-based event-delivery mechanism, a Kafka producer left alone does not emit a `COMPLETE`` event. This creates a producer for each event when we detect that we're under Airflow 2.3 - 2.5. - Spark: fix custom environment variables facet
#1973
@pawel-big-lebowski
Enables sending the Spark environment variables facet in a non-deterministic way. - Spark: filter unwanted Delta events
#1968
@pawel-big-lebowski
Clears events generated by logical plans havingProject
node as root. - Python: allow modification of
openlineage.*
logging levels via environment variables#1974
@JDarDagran
AddsOPENLINEAGE_{CLIENT/AIRFLOW/DBT}_LOGGING
environment variables that can be set according to module logging levels and cleans up some logging calls inopenlineage-airflow
.
0.29.2 - 2023-06-30
- Flink: support Flink version 1.17.1
#1947
@pawel-big-lebowski
Adds support for Flink versions 1.15.4, 1.16.2 and 1.17.1. - Spark: support Spark 3.4
#1790
@pawel-big-lebowski
Introduces support for latest Spark version 3.4.0, along with 3.2.4 and 3.3.2. - Spark: add Databricks platform integration test
#1928
@pawel-big-lebowski
Adds a Spark integration test to verify behavior on Databricks to be run manually in CircleCI when needed. - Spec: add static lineage event types
#1880
@pawel-big-lebowski
As a first step in implementing static lineage, this adds newDatasetEvent
andJobEvent
types to the spec, along with support for the new types in the Python client.
- Proxy: remove unused Golang client approach
#1926
@mobuchowski
Removes the unused Golang proxy, rendered redundant by the fluentd proxy. - Req: bump minimum supported Python version to 3.8
#1950
@mobuchowski
Python 3.7 is at EOL. This bumps the minimum supported version to 3.8 to keep the project aligned with the Python EOL schedule.
- Flink: fix
KafkaSource
withGenericRecord
#1944
@pawel-big-lebowski
Extract dataset schema fromKafkaSource
whenGenericRecord
deserialized is used. - dbt: fix security vulnerabilities
#1945
@JDarDagran
Fixes vulnerabilities in the dbt integration and integration tests.
0.28.0 - 2023-06-12
- dbt: add Databricks compatibility
#1829
Ines70
Enables launching OpenLineage with a Databricks profile.
- Fix type-checked marker and packaging
#1913
gaborbernat
The client was not marking itself as type-annotated. - Python client: add
schemaURL
to run event#1917
gaborbernat Adds the missingschemaURL
to the client'sRunState
class.
0.27.2 - 2023-06-06
- Python client: deprecate
client.from_environment
, do not skip loading config#1908
@mobuchowski
Deprecates theOpenLineage.from_environment
method and recommends using the constructor instead.
0.27.1 - 2023-06-05
- Python client: add emission filtering mechanism and exact, regex filters
#1878
@mobuchowski
Adds configurable job-name filtering to the Python client. Filters can be exact-match- or regex-based. Events will not be sent in the case of matches.
- Spark: fix column lineage for aggregate queries on databricks
#1867
@pawel-big-lebowski
Aggregate queries on databricks did not return column lineage. - Airflow: fix unquoted
[
and]
in Snowflake URIs#1883
@JDarDagran
Snowflake connections containing one of[
or]
were causingurllib.parse.urlparse
to fail.
0.26.0 - 2023-05-18
- Proxy: Fluentd proxy support (experimental)
#1757
@pawel-big-lebowski
Adds a Fluentd data collector as a proxy to buffer Openlineage events and send them to multiple backends (among many other purposes). Also implements a Fluentd Openlineage parser to validate incoming HTTP events at the beginning of the pipeline. See the readme file for more details.
- Python client: use Hatchling over setuptools to orchestrate Python env setup
#1856
@gaborbernat
Replaces setuptools with Hatchling for building the backend. Also includes a number of fixes, including to type definitions intransport
and elsewhere.
- Spark: support single file datasets
#1855
@pawel-big-lebowski
Fixes the naming of single file datasets so they are no longer named using the parent directory's path:spark.read.csv('file.csv')
. - Spark: fix
logicalPlan
serialization issue on Databricks#1858
@pawel-big-lebowski
Disables thespark_unknown
facet by default to turn off serialization oflogicalPlan
.
0.25.0 - 2023-05-15
- Spark: add Spark/Delta
merge into
support#1823
@pawel-big-lebowski
Adds support formerge into
queries.
- Spark: fix JDBC query handling
#1808
@nataliezeller1
Makes query handling more tolerant of variations in syntax and formatting. - Spark: filter Delta adaptive plan events
#1830
@pawel-big-lebowski
Extends theDeltaEventFilter
class to filter events in cases where rewritten queries in adaptive Spark plans generate extra events. - Spark: fix Java class cast exception
#1844
@Anirudh181001
Fixes the error caused by theOpenLineageRunEventBuilder
when it cast the Spark scheduler'sShuffleMapStage
to boolean. - Flink: include missing fields of Openlineage events
#1840
@pawel-big-lebowski Enriches Flink events so that missingeventTime
,runId
andjob
elements no longer produce errors.
0.24.0 - 2023-05-02
- Support custom transport types
#1795
@nataliezeller1
Adds a new interface,TransportBuilder
, for creating custom transport types without having to modify core components of OpenLineage. - Airflow: dbt Cloud integration
#1418
@howardyoo
Adds a new OpenLineage extractor for dbt Cloud that uses the dbt Cloud hook provided by Airflow to communicate with dbt Cloud via its API. - Spark: support dataset name modification using regex
#1796
@pawel-big-lebowski It is a common scenario to write Spark output datasets with a location path ending with/year=2023/month=04
. The Spark parameterspark.openlineage.dataset.removePath.pattern
introduced here allows for removing certain elements from a path with a regex pattern. - Spark: filter adaptive plan events
#1830
@pawel-big-lebowski When spark plan is optimized, it is rewritten into adaptive plan which lead to duplicate Openlineage events: per normal and per adaptive plan. This changes filters the latter one.
- Spark: catch exception when trying to obtain details of non-existing table.
#1798
@pawel-big-lebowski This mostly happens when getting table details on START event while the table is still not created. - Spark: LogicalPlanSerializer
#1792
@pawel-big-lebowski
ChangesLogicalPlanSerializer
to make use of non-shaded Jackson classes in order to serializeLogicalPlans
. Note: class names are no longer serialized. - Flink: fix Flink CI
#1801
@pawel-big-lebowski
Specifies an older image version that succeeds on CI in order to fix the Flink integration.
0.23.0 - 2023-04-20
- SQL: parser improvements to support:
copy into
,create stage
,pivot
#1742
@pawel-big-lebowski
Adds support for additional syntax available in sqlparser-rs. - dbt: add support for snapshots
#1787
@JDarDagran
Adds support for this special kind of table representing type-2 Slowly Changing Dimensions.
- Spark: change custom column lineage visitors
#1788
@pawel-big-lebowski
Makes theCustomColumnLineageVisitor
interface public to support custom column lineage.
- Spark: fix null pointer in
JobMetricsHolder
#1786
@pawel-big-lebowski
Adds a null check before runningput
to fix a NPE occurring inJobMetricsHolder
- SQL: fix query with table generator
#1783
@pawel-big-lebowski
AllowsTableFactor::TableFunction
to support queries containing table functions. - SQL: fix rust code style bug
#1785
@pawel-big-lebowski
Fixes a minor style issue invisitor.rs
.
- Airflow: Remove explicit
pass
from severalextract_on_complete
methods#1771
JDarDagran
Removes the code from three extractors.
0.22.0 - 2023-04-03
- Spark: properties facet
#1717
@tnazarew
Adds a new facet to capture specified Spark properties. - SQL: SQLParser supports
alter
,truncate
anddrop
statements#1695
@pawel-big-lebowski
Adds support for the statements to the parser. - Common/SQL: provide public interface for openlineage_sql package
#1727
@JDarDagran
Provides a.pyi
public interface file for providing typing hints. - Java client: add configurable headers to HTTP transport
#1718
@tnazarew
Adds custom header handling toHttpTransport
and the Spark integration. - Python client: create client from dictionary
#1745
@JDarDagran
Adds a newfrom_dict
method to the Python client to support creating it from a dictionary.
- Spark: remove URL parameters for JDBC namespaces
#1708
@tnazarew
Makes the namespace value from an event conform to the naming convention specified in Naming.md. - Airflow: make
OPENLINEAGE_DISABLED
case-insensitive#1705
@jedcunningham
Makes the environment variable for disabling OpenLineage in the Python client and Airflow integration case-insensitive.
- Spark: fix missing BigQuery class in column lineage
#1698
@pawel-big-lebowski
The Spark integration now checks if the BigQuery classes are available on the classpath before attempting to use them. - DBT: throw
UnsupportedDbtCommand
when finding unsupported entry inargs.which
#1724
@JDarDagran
Adjusts thedbt-ol
script to detect DBT commands inrun_results.json
only.
- Spark: remove unnecessary warnings for column lineage
#1700
@pawel-big-lebowski
Removes the warnings aboutOneRowRelation
andLocalRelation
nodes. - Spark: remove deprecated configs
#1711
@tnazarew
Removes support for deprecated configs.
0.21.1 - 2023-03-02
- Clients: add
DEBUG
logging of events to transports#1633
@mobuchowski
Ensures that theDEBUG
loglevel on properly configured loggers will always log events, regardless of the chosen transport. - Spark: add
CustomEnvironmentFacetBuilder
class#1545
New contributor @Anirudh181001
Enables the capture of custom environment variables from Spark. - Spark: introduce the new output visitors
AlterTableAddPartitionCommandVisitor
andAlterTableSetLocationCommandVisitor
#1629
New contributor @nataliezeller1
Adds visitors for extracting table names from the Spark commandsAlterTableAddPartitionCommand
andAlterTableSetLocationCommand
. The intended use case is a custom transport for the OpenMetadata lineage API. - Spark: add column lineage for JDBC relations
#1636
@tnazarew
Adds column lineage information to JDBC events with data extracted from query by the SQL parser. - SQL: add linux-aarch64 native library to Java SQL parser
#1664
@mobuchowski
Adds a Linux-ARM version of the native library. The Java SQL parser interface had only Linux-x64 and MacOS universal binary variants previously.
- Airflow: get table database in Athena extractor
#1631
New contributor @rinzool
Changes the extractor to get a table's database from thetable.schema
field or the operator default if the field isNone
.
- dbt: add dbt
seed
to the list of dbt-ol events#1649
New contributor @pohek321
Ensures thatdbt-ol test
no longer fails when run against an event seed. - Spark: make column lineage extraction in Spark support caching
#1634
@pawel-big-lebowski
Collect column lineage from Spark logical plans that contain cached datasets. - Spark: add support for a deprecated config
#1586
@tnazarew
Maps the deprecatedspark.openlineage.url
tospark.openlineage.transport.url
. - Spark: add error message in case of null in url
#1590
@tnazarew
Improves error logging in the case of undefined URLs. - Spark: collect complete event for really quick Spark jobs
#1650
@pawel-big-lebowski
Improves the collecting of OpenLineage events on SQL complete in the case of quick operations. - Spark: fix input/outputs for one node
LogicalRelation
plans#1668
@pawel-big-lebowski
For simple queries likeselect col1, col2 from my_db.my_table
that do not write output, the Spark plan contained just a single node, which was wrongly treated as both an input and output dataset. - SQL: fix file existence check in build script for openlineage-sql-java
#1613
@sekikn
Ensures that the build script works if the library is compiled solely for Linux.
- Airflow: remove
JobIdMapping
and update macros to better support Airflow version 2+#1645
@JDarDagran
Updates macros to useOpenLineageAdapter
's method to generate deterministic run UUIDs because using theJobIdMapping
utility is incompatible with Airflow 2+.
- Spark: column lineage for JDBC relations
#1636
@tnazarew- Adds column lineage info to JDBC events with data extracted form query by OL SQL parser
0.20.6 - 2023-02-10
- Airflow: add new extractor for
FTPFileTransmitOperator
#1603
@sekikn
Adds a new extractor for this Airflow operator serving legacy systems.
- Airflow: make extractors for async operators work
#1601
@JDarDagran
Sends a deterministic Run UUID for Airflow runs.
- dbt: render actual profile only in profiles.yml
#1599
@mobuchowski
Adds aninclude_section
argument for the Jinja render method to include only one profile if needed. - dbt: make
compiled_code
optional#1595
@JDarDagran
Makescompiled_code
optional for manifest > v7.
0.20.4 - 2023-02-07
- Airflow: add new extractor for
GCSToGCSOperator
#1495
@sekikn
Adds a new extractor for this operator. - Flink: resolve topic names from regex, support 1.16.0
#1522
@pawel-big-lebowski
Adds support for Flink 1.16.0 and makes the integration resolve topic names from Kafka topic patterns. - Proxy: implement lineage event validator for client proxy
#1469
@fm100
Implements logic in the proxy (which is still in development) for validating and handling lineage events.
- CI: use
ruff
instead of flake8, isort, etc., for linting and formatting#1526
@mobuchowski
Adopts theruff
package, which combines several linters and formatters into one fast binary.
- Airflow: make the Trino catalog non-mandatory
#1572
@JDarDagran
Makes the Trino catalog optional in the Trino extractor. - Common: add explicit SQL dependency
#1532
@mobuchowski
Addresses a 0.19.2 breaking change to the GE integration by including the SQL dependency explicitly. - DBT: adjust
tqdm
logging indbt-ol
#1549
@JdarDagran
Adjuststqdm
to show the correct number of iterations and adds START events for parent runs. - DBT: fix typo in log output
#1493
@denimalpaca
Fixes 'emittled' typo in log output. - Great Expectations/Airflow: follow Snowflake dataset naming rules
#1527
@mobuchowski
Normalizes Snowflake dataset and datasource naming rules among DBT/Airflow/GE; canonizes old Snowflake account paths around making them all full-size with account, region and cloud names. - Java and Python Clients: Kafka does not initialize properties if they are empty; check and notify about Confluent-Kafka requirement
#1556
@mobuchowski
Fixes the failure to initializeKafkaTransport
in the Java client and adds an exception if the requiredconfluent-kafka
module is missing from the Python client. - Spark: add square brackets for list-based Spark configs
#1507
@Varunvaruns9
Adds a condition to treat configs with[]
as lists. Note:[]
will be required for list-based configs starting with 0.21.0. - Spark: fix several Spark/BigQuery-related issues
#1557
@mobuchowski
Fixes the assumption that a version is always a number; adds support forHadoopMapReduceWriteConfigUtil
; makes the integration accessBigQueryUtil
andgetTableId
using reflection, which supports all BigQuery versions; makes logs provide the full serialized LogicalPlan ondebug
. - SQL: only report partial failures `#1479 @mobuchowski
Changes the parser so it reports partial failures instead of failing the whole extraction.
0.19.2 - 2023-01-04
- Airflow: add Trino extractor
#1288
@sekikn
Adds a Trino extractor to the Airflow integration. - Airflow: add
S3FileTransformOperator
extractor#1450
@sekikn
Adds anS3FileTransformOperator
extractor to the Airflow integration. - Airflow: add standardized run facet
#1413
@JDarDagran
Creates one standardized run facet for the Airflow integration. - Airflow: add
NominalTimeRunFacet
andOwnershipJobFacet
#1410
@JDarDagran
AddsnominalEndTime
andOwnershipJobFacet
fields to the Airflow integration. - dbt: add support for postgres datasources
#1417
@julienledem
Adds the previously unsupported postgres datasource type. - Proxy: add client-side proxy (skeletal version)
#1439
#1420
@fm100
Implements a skeletal version of a client-side proxy. - Proxy: add CI job to publish Docker image
#1086
@wslulciuc
Includes a script to build and tag the image plus jobs to verify the build on every CI run and publish to Docker Hub. - SQL: add
ExtractionErrorRunFacet
#1442
@mobuchowski
Adds a facet to the spec to reflect internal processing errors, especially failed or incomplete parsing of SQL jobs. - SQL: add column-level lineage to SQL parser
#1432
#1461
@mobuchowski @StarostaGit
Adds support for extracting column-level lineage from SQL statements in the parser, including adjustments to Rust-Python and Rust-Java interfaces and the Airflow integration's SQL extractor to make use of the feature. Also includes more tests, removal of the old parser, and removal of the common-build cache in CI (which was breaking the parser). - Spark: pass config parameters to the OL client
#1383
@tnazarew
Adds a mechanism for making new lineage consumers transparent to the integration, easing the process of setting up new types of consumers.
- Airflow: fix
collect_ignore
, add flags to Pytest for cleaner output#1437
@JDarDagran
Removes theextractors
directory from the ignored list, improving unit testing. - Spark & Java client: fix README typos @versaurabh
Fixes typos in the SPDX license headers.
0.18.0 - 2022-12-08
- Airflow: support
SQLExecuteQueryOperator
#1379
@JDarDagran
Changes theSQLExtractor
and adds support for the dynamic assignment of extractors based onconn_type
. - Airflow: introduce a new extractor for
SFTPOperator
#1263
@sekikn
Adds an extractor for tracing file transfers between local file systems. - Airflow: add Sagemaker extractors
#1136
@fhoda
Creates extractors forSagemakerProcessingOperator
andSagemakerTransformOperator
. - Airflow: add S3 extractor for Airflow operators
#1166
@fhoda
Creates an extractor for theS3CopyObject
in the Airflow integration. - Airflow: implement DagRun listener
#1286
@mobuchowski
OpenLineage integration will now explicitly emit DagRun start and DagRun complete or DagRun failed events, which allows precise tracking of single dags. - Spec: add spec file for
ExternalQueryRunFacet
#1262
@howardyoo
Adds a spec file to make this facet available for the Java client. Includes a README - Docs: add a TSC doc
#1303
@merobi-hub
Adds a document listing the members of the Technical Steering Committee.
- Spark: enable usage of other Transports via Spark configuration
#1383
@tnazarew- OL client argument parsing moved from Spark Integration to java client
- Spark: improve Databricks to send better events
#1330
@pawel-big-lebowski
Filters unwanted events and provides a meaningful job name. - Spark-Bigquery: fix a few of the common errors
#1377
@mobuchowski
Fixes a few of the common issues with the Spark-Bigquery integration and adds an integration test and configures CI. - Python: validate
eventTime
field in Python client#1355
@pawel-big-lebowski
Validates theeventTime
of aRunEvent
within the client library. - Databricks: Handle Databricks Runtime 11.3 changes to
DbFsUtils
constructor#1351
@wjohnson
Recaptures lost mount point information from theDatabricksEnvironmentFacetBuilder
and environment-properties facet by looking at the number of parameters in theDbFsUtils
constructor to determine the runtime version.
0.17.0 - 2022-11-16
- Spark: support latest Spark 3.3.1
#1183
@pawel-big-lebowski
Adds support for the latest Spark 3.3.1 version. - Spark: add Kinesis Transport and support config Kinesis in Spark integration
#1200
@yogayang
Adds support for sending to Kinesis from the Spark integration. - Spark: Disable specified facets
#1271
@pawel-big-lebowski
Adds the ability to disable specified facets from generated OpenLineage events. - Python: add facets implementation to Python client
#1233
@pawel-big-lebowski
Adds missing facets to the Python client. - SQL: add Rust parser interface
#1172
@StarostaGit @mobuchowski
Implements a Java interface in the Rust SQL parser, including a build script, native library loading mechanism, CI support and build fixes. - Proxy: add helm chart for the proxy backed
#1068
@wslulciuc
Adds a helm chart for deploying the proxy backend on Kubernetes. - Spec: include possible facets usage in spec
#1249
@pawel-big-lebowski
Extends thefacets
definition with a list of available facets. - Website: publish YML version of spec to website
#1300
@rossturk
Adds configuration necessary to make the OpenLineage website auto-generate openAPI docs when the spec is published there. - Docs: update language on nominating new committers
#1270
@rossturk
Updates the governance language to reflect the new policy on nominating committers.
- Website: publish spec into new website repo location
#1295
@rossturk
Creates a new deploy key, adds it to CircleCI & GitHub, and makes the necessary changes to therelease.sh
script. - Airflow: change how pip installs packages in tox environments
#1302
@JDarDagran
Use deprecated resolver and constraints files provided by Airflow to avoid potential issues caused by pip's new resolver.
- Airflow: fix README for running integration test
#1238
@sekikn
Updates the README for consistency with supported Airflow versions. - Airflow: add
task_instance
argument toget_openlineage_facets_on_complete
#1269
@JDarDagran
Adds thetask_instance
argument toDefaultExtractor
. - Java client: fix up all artifactory paths
#1290
@harels
Not all artifactory paths were changed in the build CI script in a previous PR. - Python client: fix Mypy errors and adjust to PEP 484
#1264
@JDarDagran
Adds a--no-namespace-packages
argument to the Mypy command and adjusts code to PEP 484. - Website: release all specs since
last_spec_commit_id
, not just HEAD~1#1298
@rossturk
The script now ships all specs that have changed since.last_spec_commit_id
.
- Deprecate HttpTransport.Builder in favor of HttpConfig
#1287
@collado-mike
Deprecates the Builder in favor of HttpConfig only and replaces the existing Builder implementation by delegating to the HttpConfig.
0.16.1 - 2022-11-03
- Airflow: add
dag_run
information to Airflow version run facet#1133
@fm100
Adds the Airflow DAG run ID to thetaskInfo
facet, making this additional information available to the integration. - Airflow: add
LoggingMixin
to extractors#1149
@JDarDagran
Adds aLoggingMixin
class to the custom extractor to make the output consistent with general Airflow and OpenLineage logging settings. - Airflow: add default extractor
#1162
@mobuchowski
Adds aDefaultExtractor
to support the default implementation of OpenLineage for external operators without the need for custom extractors. - Airflow: add
on_complete
argument inDefaultExtractor
#1188
@JDarDagran
Adds support for running another method onextract_on_complete
. - SQL: reorganize the library into multiple packages
#1167
@StarostaGit @mobuchowski
Splits the SQL library into a Rust implementation and foreign language bindings, easing the process of adding language interfaces. Also contains CI fix.
- Airflow: move
get_connection_uri
as extractor's classmethod#1169
@JDarDagran
Theget_connection_uri
method allowed for too many params, resulting in unnecessarily long URIs. This changes the logic to whitelisting per extractor. - Airflow: change
get_openlineage_facets_on_start/complete
behavior#1201
@JDarDagran
Splits up the method for greater legibility and easier maintenance.
- Airflow: always send SQL in
SqlJobFacet
as a string#1143
@mobuchowski
Changes the data type ofquery
from array to string to an fix error in theRedshiftSQLOperator
. - Airflow: include
__extra__
case when filtering URI query params#1144
@JDarDagran
Includes theconn.EXTRA_KEY
in theget_connection_uri
method to avoid exposing secrets in URIs via the__extra__
key. - Airflow: enforce column casing in
SQLCheckExtractor
s#1159
@denimalpaca
Uses the parent extractor's_is_uppercase_names
property to determine if the column should be upper cased in theSQLColumnCheckExtractor
's_get_input_facets()
method. - Spark: prevent exception when no schema provided
#1180
@pawel-big-lebowski
Prevents evaluation of column lineage when theschemFacet
isnull
. - Great Expectations: add V3 API compatibility
#1194
@denimalpaca
Fixes the Pandas datasource to make it V3 API-compatible.
- Airflow: remove support for Airflow 1.10
#1128
@mobuchowski
Removes the code structures and tests enabling support for Airflow 1.10.
0.15.1 - 2022-10-05
- Airflow: improve development experience
#1101
@JDarDagran
Adds an interactive development environment to the Airflow integration and improves integration testing. - Spark: add description for URL parameters in readme, change
overwriteName
toappName
#1130
@tnazarew
Adds more information about passing arguments withspark.openlineage.url
and changesoverwriteName
toappName
for clarity. - Documentation: update issue templates for proposal & add new integration template
#1116
@rossturk
Adds a YAML issue template for new integrations and fixes a bug in the proposal template.
- Airflow: lazy load BigQuery client
#1119
@mobuchowski
Moves import of the BigQuery client from top level to local level to decrease DAG import time.
- Airflow: fix UUID generation conflict for Airflow DAGs with same name
#1056
@collado-mike
Adds a namespace to the UUID calculation to avoid conflicts caused by DAGs having the same name in different namespaces in Airflow deployments. - Spark/BigQuery: fix issue with spark-bigquery-connector >=0.25.0
#1111
@pawel-big-lebowski
Makes the Spark integration compatible with the latest connector. - Spark: fix column lineage
#1069
@pawel-big-lebowski
Fixes a null pointer exception error and an error whenopenlineage.timeout
is not provided. - Spark: set log level of
Init OpenLineageContext
to DEBUG#1064
@varuntestaz
Prevents sensitive information from being logged unless debug mode is used. - Java client: update version of SnakeYAML
#1090
@TheSpeedding
Bumps the SnakeYAML library version to include a key bug fix. - dbt: remove requirement for
OPENLINEAGE_URL
to be set#1107
@mobuchowski
Removes erroneous check forOPENLINEAGE_URL
in the dbt integration. - Python client: remove potentially cyclic import
#1126
@mobuchowski
Hides imports to remove potentially cyclic import. - CI: build macos release package on medium resource class
#1131
@mobuchowski
Fixes failing build due to resource class being too large.
0.14.1 - 2022-09-07
- Fix Spark integration issues including error when no
openlineage.timeout
#1069
@pawel-big-lebowski
OpenlineageSparkListener
was failing when noopenlineage.timeout
was provided.
0.14.0 - 2022-09-06
- Support ABFSS and Hadoop Logical Relation in Column-level lineage
#1008
@wjohnson
Introduces anextractDatasetIdentifier
that uses similar logic toInsertIntoHadoopFsRelationVisitor
to pull out the path on the HDFS compliant file system; tested on ABFSS and DBFS (Databricks FileSystem) to prove that lineage could be extracted using non-SQL commands. - Add Kusto relation visitor
#939
@hmoazam
Implements aKustoRelationVisitor
to support lineage for Azure Kusto's Spark connector. - Add ColumnLevelLineage facet doc
#1020
@julienledem
Adds documentation for the Column-level lineage facet. - Include symlinks dataset facet
#935
@pawel-big-lebowski
Includes the recently introducedSymlinkDatasetFacet
in generated OpenLineage events. - Add support for dbt 1.3 beta's metadata changes
#1051
@mobuchowski
Makes projects that are composed of only SQL models work on 1.3 beta (dbt 1.3 renamed thecompiled_sql
field tocompiled_code
to support Python models). Does not provide support for dbt's Python models. - Support Flink 1.15
#1009
@mzareba382
Adds support for Flink 1.15. - Add Redshift dialect to the SQL integration
#1066
@mobuchowski
Adds support for Redshift's SQL dialect in OpenLineage's SQL parser, including quirks such as the use of square brackets in JSON paths. (Note, this does not add support for all of Redshift's custom syntax.)
- Make the timeout configurable in the Spark integration
#1050
@tnazarew
Makes timeout configurable by the user. (In some cases, the time needed to send events was longer than 5 seconds, which exceeded the timeout value.)
- Add a dialect parameter to Great Expectations SQL parser calls
#1049
@collado-mike
Specifies the dialect name from the SQL engine. - Fix Delta 2.1.0 with Spark 3.3.0
#1065
@pawel-big-lebowski
Allows delta support for Spark 3.3 and fixes potential issues. (The Openlineage integration for Spark 3.3 was turned on without delta support, as delta did not support Spark 3.3 at that time.)
0.13.1 - 2022-08-25
- Rename all
parentRun
occurrences toparent
in Airflow integration1037
@fm100
Changes theparentRun
property name toparent
in the Airflow integration to match the spec. - Do not change task instance during
on_running
event1028
@JDarDagran
Fixes an issue in the Airflow integration with theon_running
hook, which was changing theTaskInstance
object along with thetask
attribute.
0.13.0 - 2022-08-22
- Add BigQuery check support
#960
@denimalpaca
Adds logic and support for proper dynamic class inheritance for BigQuery-style operators. (BigQuery's extractor needed additional logic to support the forthcomingBigQueryColumnCheckOperator
andBigQueryTableCheckOperator
.) - Add
RUNNING
EventType
in spec and Python client#972
@mzareba382
Introduces aRUNNING
event state in the OpenLineage spec to indicate a running task and adds aRUNNING
event type in the Python API. - Use databases & schemas in SQL Extractors
#974
@JDarDagran
Allows the Airflow integration to differentiate between databases and schemas. (There was no notion of databases and schemas when querying and parsing results frominformation_schema
tables.) - Implement Event forwarding feature via HTTP protocol
#995
@howardyoo
AddsHttpLineageStream
to forward a given OpenLineage event to any HTTP endpoint. - Introduce
SymlinksDatasetFacet
to spec#936
@pawel-big-lebowski
Creates a new facet, theSymlinksDatasetFacet
, to support the storing of alternative dataset names. - Add Azure Cosmos Handler to Spark integration
#983
@hmoazam
Defines a new interface, theRelationHandler
, to support Spark data sources that do not haveTableCatalog
,Identifier
, orTableProperties
set, as is the case with the Azure Cosmos DB Spark connector. - Support OL Datasets in manual lineage inputs/outputs
#1015
@conorbev
Allows Airflow users to create OpenLineage Dataset classes directly in DAGs with no conversion necessary. (Manual lineage definition required users to create anairflow.lineage.entities.Table
, which was then converted to an OpenLineage Dataset.) - Create ownership facets
#996
@julienledem
Adds an ownership facet to both Dataset and Job in the OpenLineage spec to capture ownership of jobs and datasets.
- Use
RUNNING
EventType in Flink integration for currently running jobs#985
@mzareba382
Makes use of the newRUNNING
event type in the Flink integration, changing events sent by Flink jobs fromOTHER
to this new type. - Convert task objects to JSON-encodable objects when creating custom Airflow version facets
#1018
@fm100
Implements ato_json_encodable
function in the Airflow integration to make task objects JSON-encodable.
- Add support for custom SQL queries in v3 Great Expectations API
#1025
@collado-mike
Fixes support for custom SQL statements in the Great Expectations provider. (The Great Expectations custom SQL datasource was not applied to the support for the V3 checkpoints API.)
0.12.0 - 2022-08-01
- Add Spark 3.3.0 support
#950
@pawel-big-lebowski - Add Apache Flink integration
#951
@mobuchowski - Add ability to extend column level lineage mechanism
#922
@pawel-big-lebowski - Add ErrorMessageRunFacet
#897
@mobuchowski - Add SQLCheckExtractors
#717
@denimalpaca - Add RedshiftSQLExtractor & RedshiftDataExtractor
#930
@JDarDagran - Add dataset builder for AlterTableCommand
#927
@tnazarew
- Limit Delta events
#905
@pawel-big-lebowski - Airflow integration: allow lineage metadata to flow through inlets and outlets
#914
@fenil25
- Limit size of serialized plan
#917
@pawel-big-lebowski - Fix noclassdef error
#942
@pawel-big-lebowski
0.11.0 - 2022-07-07
- HTTP option to override timeout and properly close connections in
openlineage-java
lib.#909
@mobuchowski - Dynamic mapped tasks support to Airflow integration
#906
@JDarDagran SqlExtractor
to Airflow integration#907
@JDarDagran- PMD to Java and Spark builds in CI
#898
@merobi-hub
- When testing extractors in the Airflow integration, set the extractor length assertion dynamic
#882
@denimalpaca - Render templates as start of integration tests for
TaskListener
in the Airflow integration#870
@mobuchowski
- Dependencies bundled with
openlineage-java
lib.#855
@collado-mike - PMD reported issues
#891
@pawel-big-lebowski - Spark casting error and session catalog support for
iceberg
in Spark integration#856
@wslulciuc
0.10.0 - 2022-06-24
- Add static code anlalysis tool mypy to run in CI for against all python modules (
#802
) @howardyoo - Extend
SaveIntoDataSourceCommandVisitor
to extract schema fromLocalRelaiton
andLogicalRdd
in spark integration (#794
) @pawel-big-lebowski - Add
InMemoryRelationInputDatasetBuilder
forInMemory
datasets to Spark integration (#818
) @pawel-big-lebowski - Add copyright to source files
#755
@merobi-hub - Add
SnowflakeOperatorAsync
extractor support to Airflow integration#869
@merobi-hub - Add PMD analysis to proxy project (
#889
) @howardyoo
- Skip
FunctionRegistry.class
serialization in Spark integration (#828
) @mobuchowski - Install new
rust
-based SQL parser by default in Airflow integration (#835
) @mobuchowski - Improve overall
pytest
and integration tests for Airflow integration (#851
,#858
) @denimalpaca - Reduce OL event payload size by excluding local data and including output node in start events (
#881
) @collado-mike - Split spark integration into submodules (
#834
,#890
) @tnazarew @mobuchowski
- Conditionally import
sqlalchemy
lib for Great Expectations integration (#826
) @pawel-big-lebowski - Add check for missing class
org.apache.spark.sql.catalyst.plans.logical.CreateV2Table
in Spark integration (#866
) @pawel-big-lebowski - Fix static code analysis issues (
#867
,#874
) @pawel-big-lebowski
0.9.0 - 2022-06-03
- Spark: Column-level lineage introduced for Spark integration (#698, #645) @pawel-big-lebowski
- Java: Spark to use Java client directly (#774) @mobuchowski
- Clients: Add OPENLINEAGE_DISABLED environment variable which overrides config to NoopTransport (#780) @mobuchowski
- Set log to debug on unknown facet entry (#766) @wslulciuc
- Dagster: pin protobuf version to 3.20 as suggested by tests (#787) @mobuchowski
- Add SafeStrDict to skip failing attributes (#798) @JDarDagran
0.8.2 - 2022-05-19
openlineage-airflow
now supports getting credentials from Airflows secrets backend (#723) @mobuchowskiopenlineage-spark
now supports Azure Databricks Credential Passthrough (#595) @wjohnsonopenlineage-spark
detects datasets wrapped byExternalRDD
s (#746) @collado-mike
PostgresOperator
fails to retrieve host and conn during extraction (#705) @sekikn- SQL parser accepts lists of sql statements (#734) @mobuchowski
- Missing schema when writing to Delta tables in Databricks (#748) @collado-mike
0.8.1 - 2022-04-29
- Airflow integration uses new TaskInstance listener API for Airflow 2.3+ (#508) @mobuchowski
- Support for HiveTableRelation as input source in Spark integration (#683) @collado-mike
- Add HTTP and Kafka Client to
openlineage-java
lib (#480) @wslulciuc, @mobuchowski - New SQL parser, used by Postgres, Snowflake, Great Expectations integrations (#644) @mobuchowski
- GreatExpectations: Fixed bug when invoking GreatExpectations using v3 API (#683) @collado-mike
0.7.1 - 2022-04-19
- Python implements Transport interface - HTTP and Kafka transports are available (#530) @mobuchowski
- Add UnknownOperatorAttributeRunFacet and support in lineage backend (#547) @collado-mike
- Support Spark 3.2.1 (#607) @pawel-big-lebowski
- Add StorageDatasetFacet to spec (#620) @pawel-big-lebowski
- Airflow: custom extractors lookup uses only get_operator_classnames method (#656) @mobuchowski
- README.md created at OpenLineage/integrations for compatibility matrix (#663) @howardyoo
- Dagster: handle updated PipelineRun in OpenLineage sensor unit test (#624) @dominiquetipton
- Delta improvements (#626) @collado-mike
- Fix SqlDwDatabricksVisitor for Spark2 (#630) @wjohnson
- Airflow: remove redundant logging from GE import (#657) @mobuchowski
- Fix Shebang issue in Spark's wait-for-it.sh (#658) @mobuchowski
- Update parent_run_id to be a uuid from the dag name and run_id (#664) @collado-mike
- Spark: fix time zone inconsistency in testSerializeRunEvent (#681) @sekikn
0.6.2 - 2022-03-16
- CI: add integration tests for Airflow's SnowflakeOperator and dbt-snowflake @mobuchowski
- Introduce DatasetVersion facet in spec @pawel-big-lebowski
- Airflow: add external query id facet @mobuchowski
- Complete Fix of Snowflake Extractor get_hook() Bug @denimalpaca
- Update artwork @rossturk
- Airflow tasks in a DAG now report a common ParentRunFacet @collado-mike
0.6.1 - 2022-03-07
- Catch possible failures when emitting events and log them @mobuchowski
- dbt: jinja2 code using do extensions does not crash @mobuchowski
0.6.0 - 2022-03-04
- Extract source code of PythonOperator code similar to SQL facet @mobuchowski
- Add DatasetLifecycleStateDatasetFacet to spec @pawel-big-lebowski
- Airflow: extract source code from BashOperator @mobuchowski
- Add generic facet to collect environmental properties (EnvironmentFacet) @harishsune
- OpenLineage sensor for OpenLineage-Dagster integration @dalinkim
- Java-client: make generator generate enums as well @pawel-big-lebowski
- Added
UnknownOperatorAttributeRunFacet
to Airflow integration to record operators that don't produce lineage @collado-mike
- Airflow: increase import timeout in tests, fix exit from integration @mobuchowski
- Reduce logging level for import errors to info @rossturk
- Remove AWS secret keys and extraneous Snowflake parameters from connection uri @collado-mike
- Convert to LifecycleStateChangeDatasetFacet @pawel-big-lebowski
0.5.2 - 2022-02-10
- Proxy backend example using
Kafka
@wslulciuc - Support Databricks Delta Catalog naming convention with DatabricksDeltaHandler @wjohnson
- Add javadoc as part of build task @mobuchowski
- Include TableStateChangeFacet in non V2 commands for Spark @mr-yusupov
- Support for SqlDWRelation on Databricks' Azure Synapse/SQL DW Connector @wjohnson
- Implement input visitors for v2 commands @pawel-big-lebowski
- Enabled SparkListenerJobStart events to trigger open lineage events @collado-mike
- dbt: job namespaces for given dbt run match each other @mobuchowski
- Fix Breaking SnowflakeOperator Changes from OSS Airflow @denimalpaca
- Made corrections to account for DeltaDataSource handling @collado-mike
0.5.1 - 2022-01-18
- Support for dbt-spark adapter @mobuchowski
- New
backend
to proxy OpenLineage events to one or more event streams 🎉 @mandy-chessell @wslulciuc - Add Spark extensibility API with support for custom Dataset and custom facet builders @collado-mike
- airflow: fix import failures when dependencies for bigquery, dbt, great_expectations extractors are missing @lukaszlaszko
- Fixed openlineage-spark jar to correctly rename bundled dependencies @collado-mike
0.4.0 - 2021-12-13
- Spark output metrics @OleksandrDvornik
- Separated tests between Spark 2 & 3 @pawel-big-lebowski
- Databricks install README and init scripts @wjohnson
- Iceberg integration with unit tests @pawel-big-lebowski
- Kafka read and write support @OleksandrDvornik / @collado-mike
- Arbitrary parameters supported in HTTP URL construction @wjohnson
- Increased visitor coverage for Spark commands @mobuchowski / @pawel-big-lebowski
- dbt: column descriptions are properly filled from metadata.json @mobuchowski
- dbt: allow parsing artifacts with version higher than officially supported @mobuchowski
- dbt: dbt build command is supported @mobuchowski
- dbt: fix crash when build command is used with seeds in dbt 1.0.0rc3 @mobuchowski
- spark: increase logical plan visitor coverage @mobuchowski
- spark: fix logical serialization recursion issue @OleksandrDvornik
- Use URL#getFile to fix build on Windows @mobuchowski
0.3.1 - 2021-10-21
- fix import in spark3 visitor @mobuchowski
0.3.0 - 2021-10-21
- Spark3 support @OleksandrDvornik / @collado-mike
- LineageBackend for Airflow 2 @mobuchowski
- Adding custom spark version facet to spark integration @OleksandrDvornik
- Adding dbt version facet @mobuchowski
- Added support for Redshift profile @AlessandroLollo
- Sanitize JDBC URLs @OleksandrDvornik
- strip openlineage url in python client @OleksandrDvornik
- deploy spec if spec file changes @mobuchowski
0.2.3 - 2021-10-07
- Add dbt
v3
manifest support @mobuchowski
0.2.2 - 2021-09-08
- Implement OpenLineageValidationAction for Great Expectations @collado-mike
- facet: add expectations assertions facet @mobuchowski
- airflow: pendulum formatting fix, add tests @mobuchowski
- dbt: do not emit events if run_result file was not updated @mobuchowski
0.2.1 - 2021-08-27
- Default
--project-dir
argument to current directory indbt-ol
script @mobuchowski
0.2.0 - 2021-08-23
-
Parse dbt command line arguments when invoking
dbt-ol
@mobuchowski. For example:$ dbt-ol run --project-dir path/to/dir
-
Set
UnknownFacet
for spark (captures metadata about unvisited nodes from spark plan not yet supported) @OleksandrDvornik
- Remove
model
from dbt job name @mobuchowski - Default dbt job namespace to output dataset namespace @mobuchowski
- Rename
openlineage.spark.*
toio.openlineage.spark.*
@OleksandrDvornik
- Remove instance references to extractors from DAG and avoid copying log property for serializability @collado-mike
0.1.0 - 2021-08-12
OpenLineage is an Open Standard for lineage metadata collection designed to record metadata for a job in execution. The initial public release includes:
- An initial specification. The the initial version
1-0-0
of the OpenLineage specification defines the core model and facets. - Integrations that collect lineage metadata as OpenLineage events:
Apache Airflow
with support for BigQuery, Great Expectations, Postgres, Redshift, SnowflakeApache Spark
dbt
- Clients that send OpenLineage events to an HTTP backend. Both
java
andpython
are initially supported.