Skip to content

Pull requests: apache/beam

New pull request New
Clear current search query, filters, and sorts
99 Open 28,577 Closed
99 Open 28,577 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

Implement a Top partitioner python stale
#29106 opened Oct 23, 2023 by hjtran Loading…
22
Add property support to trivial_inference.py python
#36183 opened Sep 17, 2025 by hjtran Loading…
3 tasks
6
Request to use BASIC enum when calling tables.get() in BigQuery #34075 gcp io python yaml
#34249 opened Mar 11, 2025 by tamannakakkar93 • Draft
15
[IcebergIO] load tests build io java Next Action: Author synthetic
#33728 opened Jan 22, 2025 by ahmedabu98 • Draft
10
Update default max publish batch byte size calculation gcp io java
#36082 opened Sep 7, 2025 by utsav-pal Loading…
1 of 3 tasks
4
create helper function Next Action: Reviewers pinned python
#26225 opened Apr 11, 2023 by smeet07 Loading…
1 of 3 tasks
79
Added Filter and Projection Pushdown support to ParquetIO and Beam SQL's ParquetTable aws bigtable build core dataflow direct docker examples extensions flink fn-execution gcp go hadoop hbase hcatalog healthcare infra io java jdbc jet jms kafka learning local model mongodb mqtt Next Action: Reviewers parquet prism protobuf python runners samza sketching spanner spark sql synthetic tests thrift twister2 typescript vendor website yaml
#35589 opened Jul 15, 2025 by talatuyarer Loading…
3 tasks
1
21
Add Apache Iceberg support and Catalog support to Beam SQL documentation Next Action: Reviewers website
#36325 opened Sep 30, 2025 by talatuyarer Loading…
3 tasks
5
Add Iceberg Streaming Write example with Beam SQL examples java
#36287 opened Sep 25, 2025 by tarun-google • Draft
Upgrade sqlline from 1.4.0 to 1.12.0 extensions java sql
#36322 opened Sep 30, 2025 by talatuyarer Loading…
3 tasks
8
Add Kafka to Kafka RAW example pipeline configuration Next Action: Author python reassigned-reviewers yaml
#34992 opened May 18, 2025 by Ashfaqbs Loading…
23
Trigger dill workflow.
#36350 opened Oct 1, 2025 by claudevdm • Draft
3 tasks
1
Directrunnergroupintobatches python runners
#36498 opened Oct 13, 2025 by hjtran • Draft
3 tasks
[IcebergIO] Change writer open/close logs to debug io java Next Action: Author
#35240 opened Jun 11, 2025 by ahmedabu98 • Draft
3
BeamRowWrapper io java
#36125 opened Sep 11, 2025 by ahmedabu98 • Draft
[Python]Fix type inference for closures in lambdas python
#36080 opened Sep 7, 2025 by Suvrat1629 Loading…
1 of 3 tasks
1
3
Create new SubProject to not depend on Dataflow in Kafka build io java kafka Next Action: Author
#35452 opened Jun 26, 2025 by fozzie15 Loading…
3 tasks
6
Fix: Handle invalid bucket path warning in Beam Python SDK Next Action: Author python
#35744 opened Jul 30, 2025 by yquaziii Loading…
3 tasks
1
8
[BEAM-5090] Use topological sort during ProcessBundle in Java SDKHarness java
#36169 opened Sep 16, 2025 by dakshing • Draft
3 tasks
3
Default getUseStorageApiConnectionPool to true instead of false gcp io java
#35073 opened May 28, 2025 by damccorm • Draft
3 tasks
3
[SQL] Alter Catalog and Table statements extensions java sql
#36571 opened Oct 20, 2025 by ahmedabu98 • Draft
Remove unneeded base64 encoding of pickled data. python
#36359 opened Oct 2, 2025 by robertwb Loading…
3 tasks
6
[Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) io java Next Action: Author reassigned-reviewers
#35919 opened Aug 20, 2025 by Suvrat1629 Loading…
3 tasks
1
20
Add BigQuery Storage Read API Enrichment Handler examples Next Action: Author python reassigned-reviewers website
#35197 opened Jun 7, 2025 by pandasanjay Loading…
3 tasks
40
Add environment variable for skipping slow ensure_clean_state python fixture python
#36400 opened Oct 6, 2025 by hjtran Loading…
3 tasks
3
ProTip! Exclude everything labeled bug with -label:bug.