Skip to content

Pull requests: apache/beam

New pull request New
101 Open 28,985 Closed
101 Open 28,985 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

Fix CVE-2024-57699 by pinning son-smart version to 2.5.2 io java Next Action: Reviewers
#37200 opened Dec 30, 2025 by stankiewicz Loading…
3 tasks
2
fix: prevent state table collision by including system/user prefix core dataflow runners
#37195 opened Dec 28, 2025 by ShashidharM0118 Loading…
1 of 3 tasks
1
2
Update users.yml - fix bad role label Next Action: Reviewers
#37192 opened Dec 26, 2025 by pabloem Loading…
5
Iceberg CDC streaming source io java
#37191 opened Dec 26, 2025 by ahmedabu98 • Draft
23
Update CONTRIBUTING.md Next Action: Reviewers
#37187 opened Dec 26, 2025 by exploratoryprorammer Loading…
1
2
ML pipelines: RunInference - OSS Image Object detection build examples infra python website
#37186 opened Dec 25, 2025 by Amar3tto • Draft
3 tasks
1
[Bug] Fix PubsubUnboundedSink not following 1000 messages per batch limit gcp io java Next Action: Reviewers
#37178 opened Dec 24, 2025 by userzhy Loading…
1 of 3 tasks
1
3
Include logger name in FnApiLogRecordHandler log entries Next Action: Reviewers python runners
#37177 opened Dec 24, 2025 by userzhy Loading…
2 of 3 tasks
1
2
Flink 2.0 support build docker flink Next Action: Reviewers runners website
#37175 opened Dec 23, 2025 by Abacn Loading…
3 tasks
2
[yaml] - add multi-line windowing json support Next Action: Reviewers python yaml
#37174 opened Dec 23, 2025 by derrickaw Loading…
3 tasks
6
chore: udpate libraries-bom to 26.74.0-rc1 build docker java
#37165 opened Dec 22, 2025 by mpeddada1 • Draft
3
SolaceIO - add ack deadline io java
#37164 opened Dec 22, 2025 by stankiewicz Loading…
3 tasks
12
Revert "SolaceIO data loss - remove message ack from close and advanc… io java
#37162 opened Dec 22, 2025 by stankiewicz Loading…
3 tasks
3
Bump github.com/tetratelabs/wazero from 1.10.1 to 1.11.0 in /sdks dependencies Pull requests that update a dependency file go Next Action: Reviewers slow-review
#37160 opened Dec 22, 2025 by dependabot bot Loading…
4
Bump mypy-protobuf from 3.5.0 to 4.0.0 in /sdks/python dependencies Pull requests that update a dependency file python
#37159 opened Dec 22, 2025 by dependabot bot Loading…
1
feat: Add support for custom prediction routes in Vertex AI inference python yaml
#37155 opened Dec 20, 2025 by liferoad • Draft
3 tasks
1
2
[Dataflow Streaming] Add WindmillTagEncodingV2. core dataflow runners
#37151 opened Dec 19, 2025 by arunpandianp Loading…
15
Bump google.golang.org/api from 0.257.0 to 0.258.0 in /sdks dependencies Pull requests that update a dependency file go
#37149 opened Dec 19, 2025 by dependabot bot Loading…
1
Added TTL caching for BigQuery table definitions gcp io python
#37145 opened Dec 18, 2025 by AbgarSim Loading…
5
Support for EnvoyRateLimiter in Beam Python SDK examples io python
#37135 opened Dec 18, 2025 by tarun-google Loading…
1
Support DataStream batch for portable flink runner and run validation runner tests build docker flink Next Action: Reviewers runners
#37133 opened Dec 17, 2025 by Abacn Loading…
3 tasks
6
Clear side input caches of dofninvoker when finishing bundle. Add microbenchmarks for map_fn with side inputs. python runners
#37123 opened Dec 16, 2025 by scwhittle • Draft
3 tasks
1
Bump cloud.google.com/go/bigtable from 1.40.1 to 1.41.0 in /sdks dependencies Pull requests that update a dependency file go
#37120 opened Dec 16, 2025 by dependabot bot Loading…
1
Add model manager that automatically manage model across processes python
#37113 opened Dec 15, 2025 by AMOOOMA Loading…
3 tasks
3
Allow multiprocessshared to spawn process and delete directly with obj python
#37112 opened Dec 15, 2025 by AMOOOMA Loading…
3 tasks
3
ProTip! Exclude everything labeled bug with -label:bug.