Skip to content

Pull requests: apache/beam

New pull request New
125 Open 31,056 Closed
125 Open 31,056 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

[Spark] Fire processing-time timers in timestamp order runners spark
#39825 opened Aug 20, 2026 by Eliaaazzz Contributor Loading…
2 of 3 tasks
1
1
[Spark] Retain the last watermark of a source with no update in the batch runners spark
#39823 opened Aug 20, 2026 by Eliaaazzz Contributor Loading…
2 of 3 tasks
1
bigtable: Require google-cloud-bigtable>=2.42.0 and test Python BigtableIO write error surfacing gcp io Next Action: Reviewers python
#39820 opened Aug 19, 2026 by mutianf Contributor Loading…
1
1
[#18194] Include all per-module JaCoCo execution data in jacocoTestReport build
#39819 opened Aug 19, 2026 by ulofiai Loading…
1
1
JmsIO yaml python yaml
#39818 opened Aug 19, 2026 by Amar3tto Collaborator Loading…
3 tasks
2
[GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission build Next Action: Reviewers
#39811 opened Aug 19, 2026 by HansMarcus01 Contributor Loading…
6
[IcebergIO] Ensure compliance with table encryption io java
#39808 opened Aug 18, 2026 by ahmedabu98 Contributor Loading…
3 tasks
2
Remove nullness suppression in trigger implementation core Next Action: Reviewers runners
#39807 opened Aug 18, 2026 by kennknowles Member Loading…
3 tasks
2
Portable Time type (Java + model changes) java model Next Action: Reviewers
#39804 opened Aug 18, 2026 by PDGGK Contributor Loading…
5
Fix stale broken cluster connection in CassandraIO (#39788) cassandra io java Next Action: Reviewers
#39803 opened Aug 18, 2026 by sharan-malyala Contributor Loading…
11
[Python] Improve GroupByKey coder validation errors python runners
#39800 opened Aug 18, 2026 by goutamadwant Contributor Loading…
3 tasks done
1
1
Fix FlinkOrderedListState: preserve elements with same timestamp flink runners
#39795 opened Aug 17, 2026 by waterWang Loading…
1
1
[runners-spark] Support stateful ParDo in the Structured Streaming batch runner java Next Action: Reviewers runners spark
#39793 opened Aug 17, 2026 by f-loris Loading…
1
10
fix: pin httpclient5 to 5.4.3 in expansion service to fix OAUTHBEARER auth regression io java
#39790 opened Aug 17, 2026 by waterWang Loading…
1
2
[WIP] Merge Kafka Streams Runner skeleton build python runners website
#39785 opened Aug 17, 2026 by je-ik Contributor Loading…
3 tasks
fix: preserve duplicate same-timestamp elements in FlinkOrderedListState flink runners
#39783 opened Aug 17, 2026 by waterWang Loading…
1
Fix PubSub subscription path double-prefix in stale_cleaner (#39772) infra Next Action: Reviewers
#39778 opened Aug 17, 2026 by waterWang Loading…
1
1
Bound PGBKCVOperation precombine table by in-memory size (#39754) python runners
#39767 opened Aug 16, 2026 by Dharshika-11 Loading…
1
1
fix: increase AVG MathContext precision from 10 to 34 to prevent BIGINT overflow and silent precision loss extensions java Next Action: Reviewers sql
#39765 opened Aug 16, 2026 by waterWang Loading…
1
1
Add Prism integration tests for Delta IO build delta io java Next Action: Reviewers
#39764 opened Aug 16, 2026 by goutamadwant Contributor Loading…
4 tasks done
1
2
normalize KinesisIO aws io java Next Action: Reviewers python yaml
#39763 opened Aug 15, 2026 by aIbrahiim Contributor Loading…
3 tasks
1
3
Tag the Kafka write error output with the schema it actually emits io java kafka Next Action: Reviewers
#39760 opened Aug 15, 2026 by PDGGK Contributor Loading…
1
Tag the TFRecord write error output with the schema it actually emits java Next Action: Reviewers
#39759 opened Aug 15, 2026 by PDGGK Contributor Loading…
3 tasks done
4
Adds support for deading at a given Delta Lake version or timestamp delta io java Next Action: Reviewers website
#39758 opened Aug 15, 2026 by chamikaramj Contributor Loading…
3 tasks
1
Render ARRAY and ITERABLE fields that are not backed by a List java Next Action: Reviewers
#39750 opened Aug 14, 2026 by PDGGK Contributor Loading…
1
7
ProTip! Add no:assignee to see everything that’s not assigned.