Hi everyone,

We are pleased to announce the release of Apache Beam version 2.77.0.

This release brings several improvements, new features, and important fixes.

You can download the release here:
https://beam.apache.org/get-started/downloads/

Key Highlights:

Iceberg & BigQuery: Improved Iceberg integration with schema evolution
support and BigLake metastore table reads. Added schema update options
for BigQuery file loads.

Runners: Expanded Spark Structured Streaming support for stateful
processing in batch mode and improved Flink performance with
side-input caching and static split assignment.

Python & ML: Added Vertex AI Model Monitoring V2 support in
RunInference and introduced the new Sample.Any transform.

Core SDK: Improved Watch with event-time-based deduplication state
cleanup for Java and Python pipelines.

This release includes breaking changes, particularly for Java
SchemaCoder serialization and Python TensorRT users. TensorRT 10+ is
now required, and Java pipelines may need compatibility settings when
upgrading. Please review the full release notes carefully.

For detailed information on all changes, improvements, breaking
changes, and bug fixes, please see the full release notes:
https://github.com/apache/beam/releases/tag/v2.77.0

Thank you to everyone who contributed to this release!

Best regards,

The Apache Beam Team

Reply via email to