Skip to content

Pull requests: apache/beam

New pull request New
108 Open 30,392 Closed
108 Open 30,392 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

[IcebergIO] Improve TableCache io java
#38882 opened Jun 9, 2026 by ahmedabu98 Contributor Loading…
3 tasks
7
[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 sql
#38880 opened Jun 9, 2026 by Abacn Contributor Loading…
3 tasks
1
5
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
4
[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
#38854 opened Jun 9, 2026 by reuvenlax Contributor Loading…
25
Add memory profiler for Python docker python
#38853 opened Jun 9, 2026 by tvalentyn Contributor • Draft
3 tasks
1
9
pin pip>=26.1 docker Next Action: Reviewers python
#38852 opened Jun 8, 2026 by derrickaw Collaborator Loading…
3 tasks
6
feat: add configurable bigtable retries bigtable gcp io java
#38849 opened Jun 8, 2026 by brandtnewton • Draft
[OpenTelemetry] Add turning off to gcpauth extension build extensions java Next Action: Reviewers
#38846 opened Jun 8, 2026 by stankiewicz Contributor Loading…
3 tasks
7
[GSoC 2026] Kafka Streams runner — Redistribute translator + ExecutableStage type-agnostic edge Next Action: Reviewers runners
#38843 opened Jun 8, 2026 by junaiddshaukat Contributor Loading…
10
[Iceberg CDC] Add Changelog readers and update resolver io java
#38837 opened Jun 5, 2026 by ahmedabu98 Contributor • Draft
3 tasks
[Iceberg CDC] Add Snapshot Changelog Scanner io java
#38836 opened Jun 5, 2026 by ahmedabu98 Contributor • Draft
3 tasks
7
defer ConstructionTimeTest fixtures to setUpClass python
#38835 opened Jun 5, 2026 by aIbrahiim Contributor • Draft
3 tasks
ProTip! Type g p on any issue or pull request to go back to the pull request listing page.