beam icon indicating copy to clipboard operation
beam copied to clipboard

Apache Beam is a unified programming model for Batch and Streaming data processing.

Results 933 beam issues
Sort by recently updated
recently updated
newest added

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.

P1
bug
flaky_test
workflow_id: 71064177

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...

go
dependencies

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...

go
dependencies

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...

examples

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
Next Action: Reviewers

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...

python
build
website
infra
examples
docker
io
runners
dataflow

### 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...

python
task
P2

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.

python
io
mqtt
new feature
P3
ideas

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...

python
Next Action: Reviewers
yaml