Skip to content

Pull requests: apache/beam

New pull request New
113 Open 30,398 Closed
113 Open 30,398 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 Dataflow legacy worker abort loop thread death issue dataflow runners
#38894 opened Jun 10, 2026 by damccorm Contributor • Draft
4
[Python] Add UnboundedSource ValidatesRunner test on portable runners io python runners
#38892 opened Jun 10, 2026 by Eliaaazzz Contributor Loading…
1 of 3 tasks
4
[wip] DeltaLake yaml normalization delta io java model python yaml
#38891 opened Jun 10, 2026 by derrickaw Collaborator • Draft
3 tasks
Fix ml_test protobuf conflict for Yaml Xlang Direct build python
#38890 opened Jun 10, 2026 by aIbrahiim Contributor • 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 • Draft
3 tasks
1
[IcebergIO] Improve TableCache io java Next Action: Reviewers
#38882 opened Jun 9, 2026 by ahmedabu98 Contributor Loading…
3 tasks
8
[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
update iceberg add files parameters Next Action: Reviewers python yaml
#38879 opened Jun 9, 2026 by derrickaw Collaborator Loading…
3 tasks
4
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
#38873 opened Jun 9, 2026 by joaohmalves Loading…
1 of 3 tasks
1
5
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
SQL API Extensions, Usability Improvements, and Subquery Decorrelation extensions java sql
#38866 opened Jun 9, 2026 by damccorm Contributor • Draft
Support MAP type in RowJson and fix datetime parsing with spaces java
#38865 opened Jun 9, 2026 by damccorm Contributor • Draft
[FnApi] Add support for a sending header metadata when connecting to ApiServiceDescriptor under StandardProtocols.API_SERVICE_DESCRIPTOR_HEADER_METADATA java model
#38863 opened Jun 9, 2026 by scwhittle Contributor • Draft
3 tasks
Fix Xlang IO Direct installGcpTest uv cache lock build Next Action: Reviewers
#38862 opened Jun 9, 2026 by aIbrahiim Contributor Loading…
3 tasks
1
10
Allow strongly-consistent schema updates in BigQueryIO gcp io java Next Action: Reviewers
#38854 opened Jun 9, 2026 by reuvenlax Contributor Loading…
26
Add instrumentation for memory profiling in Python SDK docker python
#38853 opened Jun 9, 2026 by tvalentyn Contributor Loading…
3 tasks
1
@jrmccluskey
15
pin pip>=26.1 docker Next Action: Reviewers python
#38852 opened Jun 8, 2026 by derrickaw Collaborator Loading…
3 tasks
6
ProTip! Add no:assignee to see everything that’s not assigned.