Skip to content

Pull requests: apache/beam

New pull request New
146 Open 31,431 Closed
146 Open 31,431 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 OpenTelemetry tracing support to SolaceIO build io java Next Action: Reviewers
#40187 opened Sep 20, 2026 by singhmrinal02 Loading…
4
Kafka Streams runner: target flush markers across repartition topics runners
#40186 opened Sep 19, 2026 by junaiddshaukat Contributor Loading…
2
Several small updates to YAML ML examples Next Action: Reviewers python yaml
#40185 opened Sep 18, 2026 by chamikaramj Contributor Loading…
3 tasks
1
[Python] Make read and write buffer size configurable in gcsio core gcp io python
#40184 opened Sep 18, 2026 by shunping Collaborator Loading…
2
Add Python example for slowly updating global window side inputs examples Next Action: Reviewers python website
#40183 opened Sep 18, 2026 by ashwin-sampathkumar Contributor Loading…
3 tasks
7
[Python] Remove per-open metadata RPC from BeamBlobReader core gcp io python
#40182 opened Sep 18, 2026 by shunping Collaborator Loading…
2
[KafkaIO] Add with_gcp_adc and num_partitions options to Kafka SchemaTransforms and YAML io java kafka Next Action: Reviewers python yaml
#40181 opened Sep 18, 2026 by Abacn Contributor Loading…
3 tasks
4
Remove upper bound pin for cryptography. Next Action: Reviewers python
#40180 opened Sep 18, 2026 by aebrahim Contributor Loading…
1
normalize BigQuery CDC python yaml
#40177 opened Sep 18, 2026 by aIbrahiim Contributor • Draft
3 tasks
[KafkaIO] Advance idle partition watermark without requiring a record io java kafka Next Action: Reviewers
#40176 opened Sep 18, 2026 by udayaw Contributor Loading…
3 tasks
4
Bump github.com/aws/aws-sdk-go-v2/config from 1.33.3 to 1.33.5 in /sdks dependencies Pull requests that update a dependency file go Next Action: Reviewers
#40174 opened Sep 18, 2026 by dependabot Bot Loading…
1
Bump docker/setup-buildx-action from 4.3.0 to 4.4.0 build dependencies Pull requests that update a dependency file github_actions Pull requests that update GitHub Actions code
#40173 opened Sep 18, 2026 by dependabot Bot Loading…
1
Bump docker/setup-qemu-action from 4.3.0 to 4.4.0 build dependencies Pull requests that update a dependency file github_actions Pull requests that update GitHub Actions code Next Action: Reviewers
#40170 opened Sep 18, 2026 by dependabot Bot Loading…
1
Bump docker/build-push-action from 7.3.0 to 7.4.0 build dependencies Pull requests that update a dependency file github_actions Pull requests that update GitHub Actions code Next Action: Reviewers
#40169 opened Sep 18, 2026 by dependabot Bot Loading…
1
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.3 to 1.23.7 in /sdks dependencies Pull requests that update a dependency file go Next Action: Reviewers
#40168 opened Sep 18, 2026 by dependabot Bot Loading…
2
AddFiles: Add dry_run iceberg Iceberg IO connector io java Next Action: Reviewers python yaml
#40167 opened Sep 18, 2026 by claudevdm Collaborator Loading…
3 tasks
3
[Go SDK] PostgreSQLIO core configuration, write sinks, and auth providers go io Next Action: Reviewers
#40166 opened Sep 18, 2026 by jk-shah Loading…
2 of 3 tasks
2
[Python] Honor disableCounterMetrics, disableStringSetMetrics and disableBoundedTrieMetrics experiments core Next Action: Reviewers python runners
#40165 opened Sep 17, 2026 by anishmehta24 Loading…
2 of 3 tasks
1
5
Fix JaCoCo coverage for multiple test tasks. build Next Action: Reviewers
#40164 opened Sep 17, 2026 by singhmrinal02 Loading…
2
AddFiles: per-file coverage check and pinned-column enforcement in Co… iceberg Iceberg IO connector io java
#40163 opened Sep 17, 2026 by claudevdm Collaborator Loading…
3 tasks
2.77.0 Release
4
[Iceberg CDC sink] Top API layer iceberg Iceberg IO connector io java
#40161 opened Sep 17, 2026 by ahmedabu98 Contributor • Draft
3 tasks
[Go SDK] Add portable logical type registration and standard date and micros_instant types core go Next Action: Reviewers
#40154 opened Sep 17, 2026 by Eliaaazzz Contributor Loading…
2 of 3 tasks
1
[Go SDK] Convert logical type arguments to and from schema protos core go Next Action: Reviewers
#40153 opened Sep 17, 2026 by Eliaaazzz Contributor Loading…
2 of 3 tasks
2
[Go SDK] Encode INT16 row fields as big endian to match Java and Python core go Next Action: Reviewers
#40152 opened Sep 17, 2026 by Eliaaazzz Contributor Loading…
2 of 3 tasks
1
4
Flink dropping watermarks hold fix flink Next Action: Reviewers runners
#40149 opened Sep 17, 2026 by CarloMariaProietti Loading…
3 tasks
1
3
ProTip! What’s not been updated in a month: updated:<2026-08-20.