We are happy to present the new 2.58.0 release of Beam. This release includes both improvements and new functionality. See the download page for this release.
For more information about changes in 2.58.0, check out the detailed release notes (https://github.com/apache/beam/milestone/22.) I/Os - Support for Solace source (SolaceIO.Read) added (Java) ( https://github.com/apache/beam/issues/31440). New Features / Improvements - Multiple RunInference instances can now share the same model instance by setting the model_identifier parameter (Python) ( https://github.com/apache/beam/issues/31665). - Added options to control the number of Storage API multiplexing connections (https://github.com/apache/beam/issues/31721) - [BigQueryIO] Better handling for batch Storage Write API when it hits AppendRows throughput quota (https://github.com/apache/beam/issues/31837) - [IcebergIO] All specified catalog properties are passed through to the connector (https://github.com/apache/beam/issues/31726) - Removed a third-party LGPL dependency from the Go SDK ( https://github.com/apache/beam/issues/31765). - Support for MapState and SetState when using Dataflow Runner v1 with Streaming Engine (Java) (https://github.com/apache/beam/issues/18200) Breaking Changes - [IcebergIO] IcebergCatalogConfig was changed to support specifying catalog properties in a key-store fashion ( https://github.com/apache/beam/issues/31726) - [SpannerIO] Added validation that query and table cannot be specified at the same time for SpannerIO.read(). Previously withQuery overrides withTable, if set (https://github.com/apache/beam/issues/24956) Bug Fixes - [BigQueryIO] Fixed a bug in batch Storage Write API that frequently exhausted concurrent connections quota ( https://github.com/apache/beam/issues/31710) Thanks, Jack McCluskey -- Jack McCluskey SWE - DataPLS PLAT/ Dataflow ML RDU jrmcclus...@google.com
