Skip to main content
Version: Next

1.50.0 - 2026-06-18

Added​

  • Client/Java: Add timeout-aware run event emission support #4613 @jsingh-yelp Add a timeout-aware emit overload to the Java client and Transport API, allowing callers to provide a bounded wait when emitting RunEvents; Kafka transport uses the timeout to wait for producer acknowledgement before returning.
  • Flink: Add support for OpenLineage events in detached Flink Session Mode #4596 @jsingh-yelp Enable full OpenLineage lifecycle events (RUNNING, COMPLETE, FAIL) for Flink jobs submitted in detached Session Mode by introducing OpenLineageDetachedJobStatusChangedListener that initialises the Flink job ID from the REST API, bypassing the missing JobCreatedEvent on the JobManager side.

Fixed​

  • Flink: Emit ABORT event for canceled jobs instead of FAIL #4615 @wangxiaojing Map JobStatus.CANCELED to EventType.ABORT in Flink 2 job status handling; previously all non-FINISHED terminal statuses were mapped to FAIL, causing user-canceled jobs to appear as failures in downstream OpenLineage consumers.
  • Python: Fix env var facet overwriting event-supplied values #4635 @kacpermuda Merge client-configured environment variables into any environmentVariables facet already set by the producer instead of replacing it; event-supplied values take precedence and a warning is logged on conflict.
  • Spark: Fix missing Iceberg scan report facet using scanReportSupplier #4633 @fm100 Fix missing IcebergScanReport input dataset facet in CTAS/RTAS queries by reading the report directly from scanReportSupplier when available, rather than relying on OpenLineageMetricsReporter which is registered after the scan has already occurred.