Skip to content

Pull requests: apache/beam

New pull request New
116 Open 30,420 Closed
116 Open 30,420 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

[Dataflow Streaming] Activate SourceState Finalizers before submitting workitem to harness threads dataflow runners
#38921 opened Jun 11, 2026 by arunpandianp Contributor Loading…
9
[Dataflow Streaming] [Multi Key] Drop failed work in BoundedQueueExecutor::pollWork dataflow Next Action: Reviewers runners
#38920 opened Jun 11, 2026 by arunpandianp Contributor Loading…
5
[Dataflow Streaming] [Multi Key] MultiKey failure handling + Integration dataflow runners
#38919 opened Jun 11, 2026 by arunpandianp Contributor Loading…
7
fix uv cache lock contention in parallel installGcpTest build
#38918 opened Jun 11, 2026 by aIbrahiim Contributor • Draft
3 tasks
1
3
Add MLTransform embedding benchmarks build examples infra python website
#38917 opened Jun 11, 2026 by aIbrahiim Contributor Loading…
3 tasks
9
Adds a new agent SKILL for developing new I/O connectors Next Action: Reviewers
#38910 opened Jun 10, 2026 by chamikaramj Contributor Loading…
3 tasks
8
Bump vllm from 0.10.1.1 to 0.22.0 in /sdks/python/container/ml/py312 dependencies Pull requests that update a dependency file docker python
#38909 opened Jun 10, 2026 by dependabot Bot Loading…
1
Bump torch from 2.7.1 to 2.12.0 in /sdks/python/container/ml/py312 dependencies Pull requests that update a dependency file docker Next Action: Reviewers python
#38908 opened Jun 10, 2026 by dependabot Bot Loading…
2
Add Delta Lake source to the Java Managed API delta io java model
#38902 opened Jun 10, 2026 by chamikaramj Contributor Loading…
3 tasks
8
fix parsing error for typescript for CodeQL Next Action: Reviewers website
#38898 opened Jun 10, 2026 by derrickaw Collaborator Loading…
3 tasks
2
Bump vllm from 0.10.1.1 to 0.22.0 in /sdks/python/container/ml/py310 dependencies Pull requests that update a dependency file docker Next Action: Reviewers python
#38895 opened Jun 10, 2026 by dependabot Bot Loading…
1
[Python] Add UnboundedSource ValidatesRunner test on portable runners io Next Action: Reviewers python runners
#38892 opened Jun 10, 2026 by Eliaaazzz Contributor Loading…
1 of 3 tasks
7
[wip] DeltaLake yaml normalization delta io java model python yaml
#38891 opened Jun 10, 2026 by derrickaw Collaborator • Draft
3 tasks
Add metric for Kafka offset commit failures io java kafka Next Action: Reviewers
#38889 opened Jun 10, 2026 by Kriti-dev07 Loading…
5
Add BigQueryIO support for clone table creation gcp io java
#38883 opened Jun 10, 2026 by lalitx17 Contributor Loading…
3 tasks
22
[wip] spotless aws bigtable build cassandra clickhouse core dataflow direct elasticsearch euphoria examples extensions flink fn-execution gcp hadoop hcatalog healthcare infra io java jdbc jms kafka local mongodb parquet portability prism protobuf rabbitmq runners spanner spark sql synthetic tests thrift twister2 xml zetasketch
#38881 opened Jun 9, 2026 by derrickaw Collaborator • Draft
3 tasks
[SQL] Support positional parameters extensions java Next Action: Reviewers sql
#38880 opened Jun 9, 2026 by Abacn Contributor Loading…
3 tasks
1
8
Fix wordcount_rust requirements.txt and documentation examples Next Action: Reviewers python
#38877 opened Jun 9, 2026 by jrmccluskey Contributor Loading…
3 tasks
5
[IcebergIO] Support TableIdentifiers with special characters io java
#38876 opened Jun 9, 2026 by ahmedabu98 Contributor Loading…
3 tasks
7
Implement BeamFileSystemClient for Delta Lake connector delta io java Next Action: Reviewers
#38873 opened Jun 9, 2026 by joaohmalves Loading…
1 of 3 tasks
1
11
Enhance SQL Sort operator and UDF type resolution infrastructure extensions java sql
#38872 opened Jun 9, 2026 by damccorm Contributor • Draft
Add support for STDDEV_POP and STDDEV_SAMP in VarianceFn extensions java sql
#38871 opened Jun 9, 2026 by damccorm Contributor • Draft
Implement Spark SQL parser extensions and enhance analytic functions extensions java sql
#38870 opened Jun 9, 2026 by damccorm Contributor • Draft
Reconcile schema nullability in BeamCoGBKJoinRel extensions java sql
#38868 opened Jun 9, 2026 by damccorm Contributor • Draft
SQL Physical Operator Fixes and Enhancements extensions java sql
#38867 opened Jun 9, 2026 by damccorm Contributor • Draft
ProTip! Follow long discussions with comments:>50.