Bump apache-beam[gcp] from 2.28.0 to 2.43.0 in /megalist_dataflow

[dependabot]

Bumps apache-beam[gcp] from 2.28.0 to 2.43.0.

Release notes

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

Beam 2.43.0 release

We are happy to present the new 2.43.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.43.0, check out the detailed release notes.

Highlights

• Python 3.10 support in Apache Beam (#21458).
• An initial implementation of a runner that allows us to run Beam pipelines on Dask. Try it out and give us feedback! (Python) (#18962).

I/Os

• Decreased TextSource CPU utilization by 2.3x (Java) (#23193).
• Fixed bug when using SpannerIO with RuntimeValueProvider options (Java) (#22146).
• Fixed issue for unicode rendering on WriteToBigQuery (#10785)
• Remove obsolete variants of BigQuery Read and Write, always using Beam-native variant (#23564 and #23559).
• Bumped google-cloud-spanner dependency version to 3.x for Python SDK (#21198).

New Features / Improvements

• Dataframe wrapper added in Go SDK via Cross-Language (with automatic expansion service). (Go) (#23384).
• Name all Java threads to aid in debugging (#23049).
• An initial implementation of a runner that allows us to run Beam pipelines on Dask. (Python) (#18962).
• Allow configuring GCP OAuth scopes via pipeline options. This unblocks usages of Beam IOs that require additional scopes. For example, this feature makes it possible to access Google Drive backed tables in BigQuery (#23290).
• An example for using Python RunInference from Java (#23290).

Breaking Changes

• CoGroupByKey transform in Python SDK has changed the output typehint. The typehint component representing grouped values changed from List to Iterable, which more accurately reflects the nature of the arbitrarily large output collection. #21556 Beam users may see an error on transforms downstream from CoGroupByKey. Users must change methods expecting a List to expect an Iterable going forward. See document for information and fixes.
• The PortableRunner for Spark assumes Spark 3 as default Spark major version unless configured otherwise using --spark_version. Spark 2 support is deprecated and will be removed soon (#23728).

Bugfixes

• Fixed Python cross-language JDBC IO Connector cannot read or write rows containing Numeric/Decimal type values (#19817).

List of Contributors

According to git shortlog, the following people contributed to the 2.43.0 release. Thank you to all contributors!

Ahmed Abualsaud AlexZMLyu Alexey Romanenko

... (truncated)

Changelog

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

[2.43.0] - 2022-11-17

Highlights

• Python 3.10 support in Apache Beam (#21458).
• An initial implementation of a runner that allows us to run Beam pipelines on Dask. Try it out and give us feedback! (Python) (#18962).

I/Os

• Decreased TextSource CPU utilization by 2.3x (Java) (#23193).
• Fixed bug when using SpannerIO with RuntimeValueProvider options (Java) (#22146).
• Fixed issue for unicode rendering on WriteToBigQuery (#10785)
• Remove obsolete variants of BigQuery Read and Write, always using Beam-native variant (#23564 and #23559).
• Bumped google-cloud-spanner dependency version to 3.x for Python SDK (#21198).

New Features / Improvements

• Dataframe wrapper added in Go SDK via Cross-Language (with automatic expansion service). (Go) (#23384).
• Name all Java threads to aid in debugging (#23049).
• An initial implementation of a runner that allows us to run Beam pipelines on Dask. (Python) (#18962).
• Allow configuring GCP OAuth scopes via pipeline options. This unblocks usages of Beam IOs that require additional scopes. For example, this feature makes it possible to access Google Drive backed tables in BigQuery (#23290).
• An example for using Python RunInference from Java (#23290).
• Data can now be read from BigQuery and directly plumbed into a DeferredDataframe in the Dataframe API. Users no longer have to re-specify the schema in this case (#22907).

Breaking Changes

• CoGroupByKey transform in Python SDK has changed the output typehint. The typehint component representing grouped values changed from List to Iterable, which more accurately reflects the nature of the arbitrarily large output collection. #21556 Beam users may see an error on transforms downstream from CoGroupByKey. Users must change methods expecting a List to expect an Iterable going forward. See document for information and fixes.
• The PortableRunner for Spark assumes Spark 3 as default Spark major version unless configured otherwise using --spark_version. Spark 2 support is deprecated and will be removed soon (#23728).

Bugfixes

• Fixed Python cross-language JDBC IO Connector cannot read or write rows containing Numeric/Decimal type values (#19817).

[2.42.0] - 2022-10-17

Highlights

• Added support for stateful DoFns to the Go SDK.
• Added support for Batched DoFns to the Python SDK.

New Features / Improvements

• Added support for Zstd compression to the Python SDK.
• Added support for Google Cloud Profiler to the Go SDK.

... (truncated)

Commits

• 285d917 Set version for 2.43.0 RC2
• f9a86e5 Merge pull request #24127: Update staging of Python wheels (#24114)
• 7f24715 Update staging of Python wheels (#24114)
• 9a94381 cherry pick #24041: fixing BigQuery Query retry vulnerability (#24095)
• 21b4320 Merge pull request #24070: [cherry-pick][Go SDK] Fix Dataframe wrapper issue
• 6bbbc4b skip output coder field in exp request (#24066)
• f4ab317 Merge pull request #23967: Merge pull request #23954: Emit job ids via side o...
• 6e49e08 Merge pull request #23954: Emit job ids via side output in TriggerFileLoads p...
• a4e7812 Merge pull request #23911 from kileys/revertrelease
• 55ce57c Revert "info switch"
• 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 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 #106.