Skip to main content
Version: 1.33.0

1.30.0 - 2025-03-17

Added​

  • Flink 2: added support for CheckpointFacet #3531 @pawel-big-lebowski Similar to Flink 1 integration, Flink 2 integration will emit CheckpointFacet.
  • Flink 2: include SQL comments in OL events #3528 @pawel-big-lebowski Table and field comments are available within generated OL events.

Changed​

  • Java: remove deprecated configs: 'disabledFacets' and 'timeout'. #3522 @pawel-big-lebowski Configs have been replaced with: 'facets.facet-name.disabled=true' and 'timeoutInMillis'.

Fixed​

  • Spark: enable Iceberg metrics reporting for SparkSessionCatalog. #3538 @sakjung Fixes support for metrics in Iceberg SparkSessionCatalog.
  • Spark: inject metrics reporter to Iceberg's RESTCatalog. #3515 @pawel-big-lebowski Fixes support for metrics in Iceberg RESTCatalog.
  • dbt: fix race condition on dbt log file #3535 @MassyB Fixes race condition that was happening when using structured logs output.
  • dbt: fixes handling of skipped dbt nodes #3545 @MassyB Skipped nodes no longed cause exceptions.
  • Spark: fix record count stats mixed with bytes stats #3550 @pawel-big-lebowski InputStatistics facet for Iceberg datasets no longer produces incorrect stats.
  • Spark: catch input duplicates for SubqueryAlias. #3548 @pawel-big-lebowski Subquery alias no longer is duplicating the inputs.
  • Spark: catch Java 17 add opens exception. #3552 @mobuchowski Fixes catching InaccessibleMethodException in Java 17 within SparkExtensionVisitor.

New Contributors​