Skip to content

Pull requests: apache/beam

New pull request New
103 Open 28,641 Closed
103 Open 28,641 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

added determeinistic uuid helper and updated the pickler to take in a… python
#36782 opened Nov 10, 2025 by praneetnadella Loading…
3 tasks
3
Add pluggable LineageReporter interface java
#36781 opened Nov 10, 2025 by shnapz • Draft
3 tasks
Adds SchemaFieldNumber annotations to Iceberg classes that use the SchemaCoder io java Next Action: Reviewers
#36780 opened Nov 10, 2025 by chamikaramj Loading…
3 tasks
1
2
Master Next Action: Reviewers python
#36779 opened Nov 10, 2025 by dustin12 Loading…
3 tasks
2
Dont use platform separator for docker build paths. Next Action: Reviewers python runners
#36777 opened Nov 10, 2025 by claudevdm Loading…
3 tasks
1
2
Type inference tests python
#36776 opened Nov 10, 2025 by claudevdm Loading…
3 tasks
10
split hdfs into extra python
#36773 opened Nov 10, 2025 by damccorm • Draft
3 tasks
split redis into extra python
#36772 opened Nov 10, 2025 by damccorm • Draft
3 tasks
Remove gradle-wrapper.jar from source tree build java learning Next Action: Reviewers
#36771 opened Nov 10, 2025 by snazy Loading…
3
Bump github.com/tetratelabs/wazero from 1.9.0 to 1.10.0 in /sdks dependencies Pull requests that update a dependency file go
#36768 opened Nov 10, 2025 by dependabot bot Loading…
1
Bump golang.org/x/sync from 0.17.0 to 0.18.0 in /sdks dependencies Pull requests that update a dependency file go Next Action: Reviewers
#36765 opened Nov 10, 2025 by dependabot bot Loading…
1
Changes multimap entries Iterable to make a deep copy of pending adds and deletes java Next Action: Reviewers
#36759 opened Nov 7, 2025 by acrites Loading…
3 tasks
4
Example of changing bounded read to not do the read within tryClaim. java
#36758 opened Nov 7, 2025 by scwhittle • Draft
3 tasks
Add artifactregistry.writer role to beam-github-actions service account Next Action: Reviewers
#36756 opened Nov 7, 2025 by aIbrahiim Loading…
3 tasks
5
Make RestrictionTrackers.getProgress unblocking java
#36750 opened Nov 6, 2025 by Abacn Loading…
3 tasks
15
Unpin the pip version in setupVirtualenv build Next Action: Reviewers
#36745 opened Nov 6, 2025 by jrmccluskey Loading…
3 tasks
1
[Dataflow Streaming] Reuse ByteStringOutputStream buffers in WindmillBag dataflow runners
#36742 opened Nov 6, 2025 by arunpandianp Loading…
13
[BEAM-36736] Add state sampling for timer processing in the Python SDK python runners
#36737 opened Nov 5, 2025 by ktalluri456 Loading…
1 of 3 tasks
1
15
Remove 3.9-specific branches in typehinting module Next Action: Reviewers python
#36732 opened Nov 5, 2025 by jrmccluskey Loading…
3 tasks
2
[2/3] sdks/python: sink data with Milvus Search I/O connector python
#36729 opened Nov 5, 2025 by mohamedawnallah Loading…
5 of 8 tasks
1
2
Exposed source window to AssignContext in window_mapping_fn for side inputs Next Action: Reviewers python
#36722 opened Nov 4, 2025 by alexmalao1 Loading…
3 tasks
4
Iceberg direct write io java
#36720 opened Nov 4, 2025 by tomstepp • Draft
1
[OpenTelemetry] Add OpenTelemetry options to SdkHarnessOptions build java
#36716 opened Nov 4, 2025 by sjvanrossum Loading…
3 tasks
4
Adds proto fields for overwriting fetch/write state functionality model
#36708 opened Nov 3, 2025 by wolfchris-google Loading…
3 tasks
8
Default offset deduplication for KafkaIO redistribute. io java kafka
#36690 opened Oct 30, 2025 by tomstepp • Draft
ProTip! Add no:assignee to see everything that’s not assigned.