Skip to content

Pull requests: apache/beam

New pull request New
143 Open 31,292 Closed
143 Open 31,292 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

Add examples for cloudsql python yaml
#40027 opened Sep 4, 2026 by derrickaw Collaborator • Draft
3 tasks
fix bigtable schema issue bigtable gcp io java python yaml
#40025 opened Sep 4, 2026 by derrickaw Collaborator • Draft
3 tasks
1
Fix output bugs in FnApiDoFnRunner @OnTimer and @OnWindowExpiration java
#40024 opened Sep 4, 2026 by kennknowles Member Loading…
3 tasks
fix readFromKafka schema error io java kafka python yaml
#40023 opened Sep 4, 2026 by derrickaw Collaborator • Draft
3 tasks
1
Nullness improvements for simple core transforms java
#40022 opened Sep 4, 2026 by kennknowles Member • Draft
3 tasks done
Document Python BigQuery CDC record format gcp io python website
#40021 opened Sep 4, 2026 by mukeshbhandarkar Loading…
1
1
Keep progress renewal heartbeats active through bundle teardown dataflow runners
#40020 opened Sep 4, 2026 by kennknowles Member • Draft
3 tasks done
4
[Java] Move GCP-related secret classes and tests from sdks/java/core to google-cloud-platform-core build extensions gcp java
#40019 opened Sep 4, 2026 by shunping Collaborator Loading…
4
use default SDK image and aarch64 wheel build python
#40017 opened Sep 4, 2026 by aIbrahiim Contributor Loading…
3 tasks
1
[KafkaIO] Fix off-by-one message backlog in SDF read io java kafka Next Action: Reviewers
#40016 opened Sep 4, 2026 by udayaw Contributor Loading…
3 tasks
1
Bump docker/setup-qemu-action from 4.2.0 to 4.3.0 build dependencies Pull requests that update a dependency file github_actions Pull requests that update GitHub Actions code
#40012 opened Sep 4, 2026 by dependabot Bot Loading…
2
[Java] Remove CT_CONSTRUCTOR_THROW from the global SpotBugs filter build core delta direct elasticsearch examples extensions flink fn-execution gcp io java jdbc jet kafka kudu parquet rabbitmq runners sorter spark sql xml
#40008 opened Sep 4, 2026 by mxtymoshyk Contributor Loading…
3 tasks
1
[Iceberg CDC sink] table setup io java
#40007 opened Sep 3, 2026 by ahmedabu98 Contributor Loading…
3 tasks
1
[Iceberg CDC sink] Split late data and create commit windows io java
#40006 opened Sep 3, 2026 by ahmedabu98 Contributor Loading…
3 tasks
1
[Java] Propagate downstream errors from BigQuery success output gcp io java
#40004 opened Sep 3, 2026 by bvolpato Contributor • Draft
1
AddFiles: SchemaEvolutionConfig, the public settings for the schema pre-pass io java Next Action: Reviewers
#40003 opened Sep 3, 2026 by claudevdm Collaborator Loading…
3 tasks
3
Introduce LABEL_NOTICE for PR bot
#40002 opened Sep 3, 2026 by Abacn Contributor • Draft
3 tasks
[Python] Keep BigQuery load jobs distinct for table aliases gcp io python
#40001 opened Sep 3, 2026 by bvolpato Contributor • Draft
2 of 3 tasks
1
[Python] Finish async bundles after processing outputs python
#40000 opened Sep 3, 2026 by bvolpato Contributor • Draft
2 of 3 tasks
4
[Java] Preserve BigQuery failed rows across retries gcp io java
#39999 opened Sep 3, 2026 by bvolpato Contributor • Draft
2 of 3 tasks
[Gemini] Add compatibility classes between apitools client and modern bq client gcp io Next Action: Reviewers python
#39998 opened Sep 3, 2026 by jrmccluskey Contributor Loading…
3 tasks
6
[Iceberg] CDC config and writer io java Next Action: Reviewers
#39997 opened Sep 3, 2026 by ahmedabu98 Contributor Loading…
3 tasks
6
[Python] Isolate async work by key and window python
#39996 opened Sep 3, 2026 by bvolpato Contributor • Draft
2 of 3 tasks
2
[Python] Reset BigQuery retries for each batch gcp io python
#39995 opened Sep 3, 2026 by bvolpato Contributor • Draft
2 of 3 tasks
Adds drain support to Spanner CDC source. gcp io java Next Action: Reviewers spanner
#39994 opened Sep 3, 2026 by acrites Contributor Loading…
3 tasks
6
ProTip! Type g i on any issue or pull request to go back to the issue listing page.