diff --git a/CHANGES.md b/CHANGES.md index e8e11e830d14..7b4671326049 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -100,7 +100,7 @@ [comment]: # ( When updating known issues after release, make sure also update website blog in website/www/site/content/blog.) * ([#X](https://github.com/apache/beam/issues/X)). -# [2.73.0] - 2026-04-?? +# [2.73.0] - 2026-04-29 ## Highlights diff --git a/website/www/site/config.toml b/website/www/site/config.toml index 777eddc83ee0..6b171bf63284 100644 --- a/website/www/site/config.toml +++ b/website/www/site/config.toml @@ -104,7 +104,7 @@ github_project_repo = "https://github.com/apache/beam" [params] description = "Apache Beam is an open source, unified model and set of language-specific SDKs for defining and executing data processing workflows, and also data ingestion and integration flows, supporting Enterprise Integration Patterns (EIPs) and Domain Specific Languages (DSLs). Dataflow pipelines simplify the mechanics of large-scale batch and streaming data processing and can run on a number of runtimes like Apache Flink, Apache Spark, and Google Cloud Dataflow (a cloud service). Beam also brings DSL in different languages, allowing users to easily implement their data integration processes." -release_latest = "2.72.0" +release_latest = "2.73.0" # The repository and branch where the files live in Github or Colab. This is used # to serve and stage from your local branch, but publish to the master branch. # e.g. https://github.com/{{< param branch_repo >}}/path/to/notebook.ipynb diff --git a/website/www/site/content/en/blog/beam-2.72.0.md b/website/www/site/content/en/blog/beam-2.72.0.md index 63b6c2d6091f..c479f8debe74 100644 --- a/website/www/site/content/en/blog/beam-2.72.0.md +++ b/website/www/site/content/en/blog/beam-2.72.0.md @@ -25,7 +25,7 @@ See the [download page](/get-started/downloads/#2720-2026-03-30) for this releas -For more information on changes in 2.72.0, check out the [detailed release notes](https://github.com/apache/beam/milestone/39). +For more information on changes in 2.72.0, check out the [detailed release notes](https://github.com/apache/beam/milestone/40). ## Highlights diff --git a/website/www/site/content/en/blog/beam-2.73.0.md b/website/www/site/content/en/blog/beam-2.73.0.md new file mode 100644 index 000000000000..c8ca78b513c8 --- /dev/null +++ b/website/www/site/content/en/blog/beam-2.73.0.md @@ -0,0 +1,67 @@ +--- +title: "Apache Beam 2.73.0" +date: 2026-04-29 9:00:00 -0700 +categories: + - blog + - release +authors: + - vterentev +--- + + +We are happy to present the new 2.73.0 release of Beam. +This release includes both improvements and new functionality. +See the [download page](/get-started/downloads/#2730-2026-04-29) for this release. + + + +For more information on changes in 2.73.0, check out the [detailed release notes](https://github.com/apache/beam/milestone/41). + +## Highlights + +### I/Os + +* DebeziumIO (Java): added `OffsetRetainer` interface and `FileSystemOffsetRetainer` implementation to persist and restore CDC offsets across pipeline restarts, and exposed `withStartOffset` / `withOffsetRetainer` on `DebeziumIO.Read` and the cross-language `ReadBuilder` ([#28248](https://github.com/apache/beam/issues/28248)). + +### New Features / Improvements + +* (Python) Added BigQuery CDC streaming source ([#37724](https://github.com/apache/beam/issues/37724)) +* Added `ADKAgentModelHandler` for running Google Agent Development Kit (ADK) agents (Python) ([#37917](https://github.com/apache/beam/issues/37917)). +* (Python) Added exception chaining to preserve error context in CloudSQLEnrichmentHandler, processes utilities, and core transforms ([#37422](https://github.com/apache/beam/issues/37422)). +* (Python) Added a pipeline option `--experiments=pip_no_build_isolation` to disable build isolation when installing dependencies in the runtime environment ([#37331](https://github.com/apache/beam/issues/37331)). +* (Go) Added OrderedListState support to the Go SDK stateful DoFn API ([#37629](https://github.com/apache/beam/issues/37629)). +* Added support for large pipeline options via a file (Python) ([#37370](https://github.com/apache/beam/issues/37370)). +* Supported infer schema from dataclass (Python) ([#22085](https://github.com/apache/beam/issues/22085)). Default coder for typehint-ed (or set with_output_type) for non-frozen dataclasses changed to RowCoder. To preserve the old behavior (fast primitive coder), explicitly register the type with FastPrimitiveCoder. +* Updates minimum Go version to 1.26.1 ([#37897](https://github.com/apache/beam/issues/37897)). +* (Python) Added image embedding support in `apache_beam.ml.rag` package ([#37628](https://github.com/apache/beam/issues/37628)). +* (Python) Added support for Python version 3.14 ([#37247](https://github.com/apache/beam/issues/37247)). + +### Breaking Changes + +* The Python SDK container's `boot.go` now passes pipeline options through a file instead of the `PIPELINE_OPTIONS` environment variable. If a user pairs a new Python SDK container with an older SDK version (which does not support the file-based approach), the pipeline options will not be recognized and the pipeline will fail. Users must ensure their SDK and container versions are synchronized ([#37370](https://github.com/apache/beam/issues/37370)). +* Python DoFn.with_exception_handling now respects user DoFn typehints. This can break update compatibility if coders change. It can also break pipeline compilation if existing typehints are incorrect. To update safely sepcify the pipeline option `--update_compatibility_version=2.72.0`. To fix typehints replace any incorrect typehints that were previously ignored ([#37590](https://github.com/apache/beam/issues/37590)) + +### Bugfixes + +* Fixed ProcessManager not reaping child processes, causing zombie process accumulation on long-running Flink deployments (Java) ([#37930](https://github.com/apache/beam/issues/37930)). + +### Security Fixes + +* Fixed [CVE-2023-46604](https://www.cve.org/CVERecord?id=CVE-2023-46604) (CVSS 10.0) and [CVE-2022-41678](https://www.cve.org/CVERecord?id=CVE-2022-41678) by upgrading ActiveMQ from 5.14.5 to 5.19.2 (Java) ([#37943](https://github.com/apache/beam/issues/37943)). +* Fixed [CVE-2024-1597](https://www.cve.org/CVERecord?id=CVE-2024-1597), [CVE-2022-31197](https://www.cve.org/CVERecord?id=CVE-2022-31197), and [CVE-2022-21724](https://www.cve.org/CVERecord?id=CVE-2022-21724) by upgrading PostgreSQL JDBC Driver from 42.2.16 to 42.6.2 (Java) ([#37942](https://github.com/apache/beam/issues/37942)). + +## List of Contributors + +According to git shortlog, the following people contributed to the 2.73.0 release. Thank you to all contributors! + +Abdelrahman Ibrahim, Ahmed Abualsaud, Alex Malao, Alexander Nieuwenhuijse, Andres Tiko, Andrew Crites, Arun Pandian, Bentsi Leviav, Bruno Volpato, Chamikara Jayalath, Chandra Kiran Bolla, Danny McCormick, Deji Ibrahim, Derrick Williams, Elia LIU, Esmelealem, Hannes Gustafsson, Jack McCluskey, Joey Tran, Kenneth Knowles, M Junaid Shaukat, Mansi Singh, Matej Aleksandrov, Mathijs Deelen, Mattie Fu, Praneet Nadella, Radek Stankiewicz, Radosław Stankiewicz, Reuven Lax, RuiLong J., S. Veyrié, Sakthivel Subramanian, Sam Whittle, Shubham Thakur, Shunping Huang, Subramanya V, Tarun Annapareddy, Tobias Kaymak, Valentyn Tymofieiev, Vitaly Terentyev, XQ Hu, Yi Hu, ZIHAN DAI, claudevdm, kishorepola, parveensania diff --git a/website/www/site/content/en/get-started/downloads.md b/website/www/site/content/en/get-started/downloads.md index cf37974973fe..c3a3eff7f533 100644 --- a/website/www/site/content/en/get-started/downloads.md +++ b/website/www/site/content/en/get-started/downloads.md @@ -95,16 +95,24 @@ versions denoted `0.x.y`. ### Current release -#### 2.72.0 (2026-03-30) +#### 2.73.0 (2026-04-29) -Official [source code download](https://www.apache.org/dyn/closer.lua/beam/2.72.0/apache-beam-2.72.0-source-release.zip). -[SHA-512](https://downloads.apache.org/beam/2.72.0/apache-beam-2.72.0-source-release.zip.sha512). -[signature](https://downloads.apache.org/beam/2.72.0/apache-beam-2.72.0-source-release.zip.asc). +Official [source code download](https://www.apache.org/dyn/closer.lua/beam/2.73.0/apache-beam-2.73.0-source-release.zip). +[SHA-512](https://downloads.apache.org/beam/2.73.0/apache-beam-2.73.0-source-release.zip.sha512). +[signature](https://downloads.apache.org/beam/2.73.0/apache-beam-2.73.0-source-release.zip.asc). [Release notes](https://github.com/apache/beam/releases/tag/v2.71.0) ### Archived releases +#### 2.72.0 (2026-03-30) + +Official [source code download](https://archive.apache.org/dist/beam/2.72.0/apache-beam-2.72.0-source-release.zip). +[SHA-512](https://archive.apache.org/dist/beam/2.72.0/apache-beam-2.72.0-source-release.zip.sha512). +[signature](https://archive.apache.org/dist/beam/2.72.0/apache-beam-2.72.0-source-release.zip.asc). + +[Release notes](https://github.com/apache/beam/releases/tag/v2.70.0) + #### 2.71.0 (2026-01-22) Official [source code download](https://archive.apache.org/dist/beam/2.71.0/apache-beam-2.71.0-source-release.zip).