Skip to content

Pull requests: apache/beam

New pull request New
114 Open 30,663 Closed
114 Open 30,663 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 --add-opens test JVM args for HCatalog and Dataflow worker tests dataflow hcatalog io java runners
#39351 opened Jul 16, 2026 by aIbrahiim Contributor Loading…
3 tasks
1
4
Bump transformers from 4.53.0 to 5.5.0 in /sdks/python/apache_beam/examples/inference/large_language_modeling dependencies Pull requests that update a dependency file examples Next Action: Reviewers python
#39350 opened Jul 16, 2026 by dependabot Bot Loading…
1
Bump actions/setup-go from 6 to 7 build dependencies Pull requests that update a dependency file github_actions Pull requests that update GitHub Actions code Next Action: Reviewers
#39349 opened Jul 16, 2026 by dependabot Bot Loading…
1
Bump zizmorcore/zizmor-action from 0.5.7 to 0.6.0 build dependencies Pull requests that update a dependency file github_actions Pull requests that update GitHub Actions code Next Action: Reviewers
#39348 opened Jul 16, 2026 by dependabot Bot Loading…
1
Bump cloud.google.com/go/pubsub from 1.50.4 to 1.51.0 in /sdks dependencies Pull requests that update a dependency file go Next Action: Reviewers
#39347 opened Jul 16, 2026 by dependabot Bot Loading…
1
Bump google.golang.org/grpc from 1.82.0 to 1.82.1 in /sdks dependencies Pull requests that update a dependency file go Next Action: Reviewers
#39346 opened Jul 16, 2026 by dependabot Bot Loading…
1
[wip] update spot try build cassandra flink hadoop io java runners spark
#39345 opened Jul 15, 2026 by derrickaw Collaborator • Draft
3 tasks
[Iceberg] Make timestamptz return new Timestamp.MICROS logical type gcp io java
#39344 opened Jul 15, 2026 by ahmedabu98 Contributor Loading…
3 tasks
8
[GSoC 2026] Kafka Streams runner: surface SDK-harness metrics as MetricResults Next Action: Reviewers runners
#39341 opened Jul 15, 2026 by junaiddshaukat Contributor Loading…
19
[Spark] Support SDF self-checkpointing and bundle finalization on the portable runner python runners spark
#39331 opened Jul 15, 2026 by Eliaaazzz Contributor • Draft
2 of 3 tasks
1
1
add language filtering for codeql build Next Action: Reviewers
#39327 opened Jul 14, 2026 by derrickaw Collaborator Loading…
3 tasks
4
Make FirestoreV1 Transform bases public for worker access gcp io java
#39324 opened Jul 14, 2026 by aIbrahiim Contributor • Draft
3 tasks
2
KeyCommitTooLarge logging improvements dataflow runners
#39316 opened Jul 14, 2026 by rwiggles Loading…
3 tasks
8
[Java] Cache DoFn invoker constructors per instance java Next Action: Reviewers
#39310 opened Jul 13, 2026 by lofifnc Loading…
3 tasks done
1
9
Substitute org.lz4:lz4-java with at.yawk.lz4:lz4-java in all subprojects build examples flink java Next Action: Reviewers runners
#39297 opened Jul 12, 2026 by sjvanrossum Contributor Loading…
3 tasks
13
[WIP] remaining iceberg cdc changes io java
#39296 opened Jul 12, 2026 by ahmedabu98 Contributor • Draft
3 tasks
docs: Document job management and interactive API protos model
#39294 opened Jul 11, 2026 by damccorm Contributor • Draft
1
docs: Document Fn Execution API protos model
#39293 opened Jul 11, 2026 by damccorm Contributor • Draft
1
docs: Document pipeline runner API protos model Next Action: Reviewers
#39292 opened Jul 11, 2026 by damccorm Contributor Loading…
7
Buffer BufferedLogger by newline to avoid log splitting docker go python
#39288 opened Jul 10, 2026 by shunping Collaborator Loading…
9
[KafkaIO] Use consumer position and lag to estimate end offsets build examples flink io java kafka runners spark
#39285 opened Jul 10, 2026 by sjvanrossum Contributor Loading…
3 tasks
13
[KafkaIO] Remove build support for Kafka clients before 3.9.2 build examples flink io java kafka Next Action: Reviewers runners spark
#39284 opened Jul 10, 2026 by sjvanrossum Contributor Loading…
3 tasks
10
IcerbergIO Load test and benchmarking build infra Next Action: Reviewers website
#39270 opened Jul 9, 2026 by Amar3tto Collaborator Loading…
3 tasks
11
[FnApi Java] Close named data stream multiplexers once no bundle is u… build extensions flink gcp infra java Next Action: Reviewers runners
#39255 opened Jul 9, 2026 by krishnamanchikalapudi Loading…
3 tasks
1
7
Support ACKNOWLEDGE_MODE for JmsIO direct io java jms runners
#39253 opened Jul 9, 2026 by Abacn Contributor Loading…
3 tasks
2
27
ProTip! Add no:assignee to see everything that’s not assigned.