Bump apache-beam[gcp] from 2.54.0 to 2.59.0

[dependabot]

Bumps apache-beam[gcp] from 2.54.0 to 2.59.0.

Release notes

Sourced from apache-beam[gcp]'s releases.

Beam 2.59.0 release

We are happy to present the new 2.59.0 release of Beam. This release includes both improvements and new functionality. See the download page for this release.

For more information on changes in 2.59.0, check out the detailed release notes.

Highlights

• Added support for setting a configureable timeout when loading a model and performing inference in the RunInference transform using with_exception_handling (#32137)
• Initial experimental support for using Prism with the Java and Python SDKs
  • Prism is presently targeting local testing usage, or other small scale execution.
  • For Java, use 'PrismRunner', or 'TestPrismRunner' as an argument to the --runner flag.
  • For Python, use 'PrismRunner' as an argument to the --runner flag.
  • Go already uses Prism as the default local runner.

I/Os

• Improvements to the performance of BigqueryIO when using withPropagateSuccessfulStorageApiWrites(true) method (Java) (#31840).
• [Managed Iceberg] Added support for writing to partitioned tables (#32102)
• Update ClickHouseIO to use the latest version of the ClickHouse JDBC driver (#32228).
• Add ClickHouseIO dedicated User-Agent (#32252).

New Features / Improvements

• BigQuery endpoint can be overridden via PipelineOptions, this enables BigQuery emulators (Java) (#28149).
• Go SDK Minimum Go Version updated to 1.21 (#32092).
• [BigQueryIO] Added support for withFormatRecordOnFailureFunction() for STORAGE_WRITE_API and STORAGE_API_AT_LEAST_ONCE methods (Java) (#31354).
• Updated Go protobuf package to new version (Go) (#21515).
• Added support for setting a configureable timeout when loading a model and performing inference in the RunInference transform using with_exception_handling (#32137)
• Adds OrderedListState support for Java SDK via FnApi.
• Initial support for using Prism from the Python and Java SDKs.

Bugfixes

• Fixed incorrect service account impersonation flow for Python pipelines using BigQuery IOs (#32030).
• Auto-disable broken and meaningless upload_graph feature when using Dataflow Runner V2 (#32159).
• (Python) Upgraded google-cloud-storage to version 2.18.2 to fix a data corruption issue (#32135).
• (Go) Fix corruption on State API writes. (#32245).

Known Issues

• Prism is under active development and does not yet support all pipelines. See #29650 for progress.
  • In the 2.59.0 release, Prism passes most runner validations tests with the exceptions of pipelines using the following features: OrderedListState, OnWindowExpiry (eg. GroupIntoBatches), CustomWindows, MergingWindowFns, Trigger and WindowingStrategy associated features, Bundle Finalization, Looping Timers, and some Coder related issues such as with Python combiner packing, and Java Schema transforms, and heterogenous flatten coders. Processing Time timers do not yet have real time support.
  • If your pipeline is having difficulty with the Python or Java direct runners, but runs well on Prism, please let us know.

For the most up to date list of known issues, see https://github.com/apache/beam/blob/master/CHANGES.md

... (truncated)

Changelog

Sourced from apache-beam[gcp]'s changelog.

[2.59.0] - 2024-09-11

Highlights

• Added support for setting a configureable timeout when loading a model and performing inference in the RunInference transform using with_exception_handling (#32137)
• Initial experimental support for using Prism with the Java and Python SDKs
  • Prism is presently targeting local testing usage, or other small scale execution.
  • For Java, use 'PrismRunner', or 'TestPrismRunner' as an argument to the --runner flag.
  • For Python, use 'PrismRunner' as an argument to the --runner flag.
  • Go already uses Prism as the default local runner.

I/Os

• Improvements to the performance of BigqueryIO when using withPropagateSuccessfulStorageApiWrites(true) method (Java) (#31840).
• [Managed Iceberg] Added support for writing to partitioned tables (#32102)
• Update ClickHouseIO to use the latest version of the ClickHouse JDBC driver (#32228).
• Add ClickHouseIO dedicated User-Agent (#32252).

New Features / Improvements

• BigQuery endpoint can be overridden via PipelineOptions, this enables BigQuery emulators (Java) (#28149).
• Go SDK Minimum Go Version updated to 1.21 (#32092).
• [BigQueryIO] Added support for withFormatRecordOnFailureFunction() for STORAGE_WRITE_API and STORAGE_API_AT_LEAST_ONCE methods (Java) (#31354).
• Updated Go protobuf package to new version (Go) (#21515).
• Added support for setting a configureable timeout when loading a model and performing inference in the RunInference transform using with_exception_handling (#32137)
• Adds OrderedListState support for Java SDK via FnApi.
• Initial support for using Prism from the Python and Java SDKs.

Bugfixes

• Fixed incorrect service account impersonation flow for Python pipelines using BigQuery IOs (#32030).
• Auto-disable broken and meaningless upload_graph feature when using Dataflow Runner V2 (#32159).
• (Python) Upgraded google-cloud-storage to version 2.18.2 to fix a data corruption issue (#32135).
• (Go) Fix corruption on State API writes. (#32245).

Known Issues

• Prism is under active development and does not yet support all pipelines. See #29650 for progress.
  • In the 2.59.0 release, Prism passes most runner validations tests with the exceptions of pipelines using the following features: OrderedListState, OnWindowExpiry (eg. GroupIntoBatches), CustomWindows, MergingWindowFns, Trigger and WindowingStrategy associated features, Bundle Finalization, Looping Timers, and some Coder related issues such as with Python combiner packing, and Java Schema transforms, and heterogenous flatten coders. Processing Time timers do not yet have real time support.
  • If your pipeline is having difficulty with the Python or Java direct runners, but runs well on Prism, please let us know.

[2.58.1] - 2024-08-15

New Features / Improvements

• Fixed issue where KafkaIO Records read with ReadFromKafkaViaSDF are redistributed and may contain duplicates regardless of the configuration. This affects Java pipelines with Dataflow v2 runner and xlang pipelines reading from Kafka, (#32196)

Known Issues

... (truncated)

Commits

• c560075 Set version for 2.59.0 RC1
• 57d5ab5 Cherry Pick #32294 (Java PrismRunner and TestPrismRunner) to the release. (#3...
• b552e0f Check experiment for hotkey logging (#32285) (#32290)
• 4173f54 Cherrypick #32276 to 2.59.0 release branch. (#32280)
• efa8dbc Set Dataflow container to release version.
• a62ff34 Better error message when trying to get Beam Schema from proto schema with St...
• ed4c03e Do not create new Executor everytime createRunner (#32272)
• 512b52a Better error when Python xlang download jar not available (#32269)
• 65f556d Update requests package to 2.32.0 (#32270)
• c5bf5fc Revert "Portable runner fixes (#32247)" (#32271)
• Additional commits viewable in compare view

Dependabot will resolve any conflicts with this PR as long as you don't alter it yourself. You can also trigger a rebase manually by commenting @dependabot rebase.

---

Dependabot commands and options

You can trigger Dependabot actions by commenting on this PR:

• @dependabot rebase will rebase this PR
• @dependabot recreate will recreate this PR, overwriting any edits that have been made to it
• @dependabot merge will merge this PR after your CI passes on it
• @dependabot squash and merge will squash and merge this PR after your CI passes on it
• @dependabot cancel merge will cancel a previously requested merge and block automerging
• @dependabot reopen will reopen this PR if it is closed
• @dependabot close will close this PR and stop Dependabot recreating it. You can achieve the same result by closing it manually
• @dependabot show <dependency name> ignore conditions will show all of the ignore conditions of the specified dependency
• @dependabot ignore this major version will close this PR and stop Dependabot creating any more for this major version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this minor version will close this PR and stop Dependabot creating any more for this minor version (unless you reopen the PR or upgrade to it yourself)
• @dependabot ignore this dependency will close this PR and stop Dependabot creating any more for this dependency (unless you reopen the PR or upgrade to it yourself)

[dependabot]

Superseded by #278.