beam
beam copied to clipboard
Apache Beam is a unified programming model for Batch and Streaming data processing.
The LoadTests Go CoGBK Flink Batch is failing over 50% of the time Please visit https://github.com/apache/beam/actions/workflows/beam_LoadTests_Go_CoGBK_Flink_batch.yml?query=is%3Afailure+branch%3Amaster to see the logs.
Bumps [github.com/aws/aws-sdk-go-v2/service/s3](https://github.com/aws/aws-sdk-go-v2) from 1.60.0 to 1.60.1. Commits d1d210d Release 2024-08-22 afb0408 Regenerated Clients 05f4492 Update partitions file 600651a Update endpoints model ebaae40 Update API model 38fe812 Release 2024-08-21 b504211 Regenerated...
Bumps [google.golang.org/api](https://github.com/googleapis/google-api-go-client) from 0.192.0 to 0.194.0. Release notes Sourced from google.golang.org/api's releases. v0.194.0 0.194.0 (2024-08-22) Features all: Auto-regenerate discovery clients (#2746) (5d61f08) Bug Fixes gen: Change HttpBody.Data from string to...
Tests run on GHA should be queued shortly.
Added Insertion and Enrichment pipeline for RAG (Retrival Augmented Generation) usecase using OpenSearch vector database #GSOC-259 ------------------------ Thank you for your contribution! Follow this checklist to help us incorporate your...
Stateful BatchElements behavior (particularly the impact on throughput) was not explained. Updating the doc string to explain what the stateful option is doing as well as how the value of...
Python 3.8 is scheduled to reach EOL in October of 2024. This PR removes support for Python 3.8 ahead of the Beam 2.60.0 release, following versioning changes in #27194 and...
### What needs to happen? Python 3.8 supports ends Oct 2024. Some Beam dependencies, such as pandas, no longer have Python 3.8 releases. We should prepare to sunset Python 3.8...
MQTT IO connector forPython SDK Imported from Jira [BEAM-12732](https://issues.apache.org/jira/browse/BEAM-12732). Original Jira may contain additional context. Reported by: ayush1995.
Add tests to validate #31974. Created separate PR due to out-of-scope changes that should avoid cherry pick into 2.58.0 release candidate. ------------------------ Thank you for your contribution! Follow this checklist...