Skip to content

Pull requests: apache/beam

New pull request New
111 Open 27,018 Closed
111 Open 27,018 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
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

Bump github.com/docker/docker from 28.0.4+incompatible to 28.1.1+incompatible in /sdks dependencies Pull requests that update a dependency file go
#34744 opened Apr 25, 2025 by dependabot bot Loading…
1
Bump google.golang.org/api from 0.229.0 to 0.230.0 in /sdks dependencies Pull requests that update a dependency file go Next Action: Reviewers
#34743 opened Apr 25, 2025 by dependabot bot Loading…
1
Only declare state backed iterables on code channel. Next Action: Reviewers python runners
#34740 opened Apr 24, 2025 by robertwb Loading…
3 tasks
1
[Do not merge] Parse struct returned from Dataflow API to BoundedTrieData build core dataflow java runners
#34738 opened Apr 24, 2025 by Abacn • Draft
3 tasks
[WIP] Flink watermark emission core flink runners
#34734 opened Apr 24, 2025 by je-ik Loading…
3 tasks
3
[WIP] Upgrade io.debezium using #33526 as a blueprint build io java
#34733 opened Apr 24, 2025 by tkaymak Loading…
3 tasks
1
Bump github.com/golang-cz/devslog from 0.0.11 to 0.0.12 in /sdks dependencies Pull requests that update a dependency file go
#34728 opened Apr 24, 2025 by dependabot bot Loading…
1
Attempt prism for pipelines with unbounded PCollections. python runners
#34721 opened Apr 24, 2025 by robertwb Loading…
3 tasks
1
[ManagedIO] Single source of truth for ManagedIO configs build gcp io java kafka python website
#34720 opened Apr 24, 2025 by ahmedabu98 Loading…
4
Remove caching for remainders of state backed iterables. java
#34718 opened Apr 23, 2025 by robertwb Loading…
3 tasks
2
Improve failure message when passing Pipeline object / PBegin objects… Next Action: Reviewers python
#34716 opened Apr 23, 2025 by TanuSharma2511 Loading…
3 tasks
1
3
Improve validation error message for chain transform Next Action: Reviewers python yaml
#34708 opened Apr 22, 2025 by shubham-j-sde Loading…
3 tasks
10
Fix handling of collections.Counter types Next Action: Reviewers python
#34706 opened Apr 22, 2025 by jrmccluskey Loading…
3 tasks
4
complete implementation of open ai text embedding with test #new Next Action: Reviewers python
#34700 opened Apr 21, 2025 by aditya0yadav Loading…
3 tasks
21
Support customizing how built-in types are pickled for cloudpickle Next Action: Reviewers python
#34699 opened Apr 21, 2025 by AdrS Loading…
5
Add option to pickler dumps() for best-effort determinism Next Action: Reviewers python runners
#34698 opened Apr 21, 2025 by AdrS Loading…
7
Enable cloudpickle by default Next Action: Reviewers python runners
#34695 opened Apr 21, 2025 by claudevdm Loading…
3 tasks
1
[DO NOT MERGE] tried to add artifactApiService fn-execution java runners
#34689 opened Apr 21, 2025 by liferoad • Draft
3 tasks
Fix: Remove duplicate mutations in flushBatch to prevent Datastore commit gcp io java Next Action: Author
#34679 opened Apr 20, 2025 by SaumilPatel03 Loading…
1 of 3 tasks
1
6
Fix loopback extensions java
#34678 opened Apr 20, 2025 by liferoad Loading…
3 tasks
1
2
Add withReshuffle(boolean) option to FileIO.matchAll() java
#34677 opened Apr 20, 2025 by s3847243 Loading…
2 of 3 tasks
1
1
Fail Fast if Resources Do Not Exist in Kafka Cluster. io java kafka Next Action: Reviewers
#34659 opened Apr 17, 2025 by fozzie15 Loading…
3 tasks
6
Fail Fast if Resources Do Not Exist in Kafka Cluster. io java kafka
#34658 opened Apr 17, 2025 by fozzie15 • Draft
3 tasks
1
Add reshuffle before triggering load jobs. gcp io python
#34657 opened Apr 17, 2025 by claudevdm Loading…
3 tasks
2.65.0 Release
13
use WindmillChannelFactory to control what types of channels to generate dataflow runners
#34653 opened Apr 17, 2025 by m-trieu Loading…
3 tasks
2
ProTip! Filter pull requests by the default branch with base:master.