-
Notifications
You must be signed in to change notification settings - Fork 4.6k
Pull requests: apache/beam
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
Bump cryptography from 47.0.0 to 48.0.1 in Python container images
docker
Next Action: Reviewers
python
#39204
opened Jul 2, 2026 by
shahar1
Contributor
Loading…
3 tasks
Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go)
gcp
go
io
java
Next Action: Reviewers
python
#39203
opened Jul 2, 2026 by
shahar1
Contributor
Loading…
2 of 3 tasks
fix: add retries and URL encoding to Unmanaged Keys Audit workflow (#39188)
Next Action: Reviewers
#39196
opened Jul 1, 2026 by
raman118
Loading…
[Gemini] Add client-side throttling to Java Remote Inference
java
#39194
opened Jul 1, 2026 by
jrmccluskey
Contributor
Loading…
3 tasks
[Flink] Bound SDF self-checkpoint residual state on the portable runner
flink
fn-execution
Next Action: Reviewers
runners
#39191
opened Jul 1, 2026 by
Eliaaazzz
Contributor
Loading…
2 of 3 tasks
Fix Validate Go SDK Release Candidate workflow
build
Next Action: Reviewers
#39189
opened Jul 1, 2026 by
Amar3tto
Collaborator
Loading…
3 tasks
Remove previous workarounds for when
super() could not be pickled on Py3
examples
Next Action: Reviewers
python
#39187
opened Jul 1, 2026 by
ByteFlowing1337
Loading…
Update managed-io.md for release 2.75.0-RC1
Next Action: Reviewers
website
#39178
opened Jun 30, 2026 by
shunping
Collaborator
Loading…
[GSoC 2026] Fixing the github action Unmanaged Service Account Keys
build
#39177
opened Jun 30, 2026 by
HansMarcus01
Contributor
Loading…
Fix lost state updates in Set state
Next Action: Reviewers
python
runners
#39175
opened Jun 30, 2026 by
shunping
Collaborator
Loading…
fix flakey fileiotest
java
Next Action: Reviewers
#39174
opened Jun 30, 2026 by
derrickaw
Collaborator
Loading…
3 tasks
Fix CloudML TFT benchmark deps for manylinux_2_28 Dataflow workers
examples
Next Action: Reviewers
python
runners
#39162
opened Jun 29, 2026 by
aIbrahiim
Contributor
Loading…
3 tasks
[Interactive Beam] Fix caching deadlock, wait race conditions, and stale graph in notebooks
Next Action: Reviewers
python
runners
#39161
opened Jun 29, 2026 by
ian-Liaozy
Contributor
Loading…
1 of 3 tasks
Add query_output_schema to ReadFromBigQuery for BEAM_ROW + query support
gcp
io
python
yaml
#39160
opened Jun 29, 2026 by
nikitagrover19
Contributor
Loading…
1 of 3 tasks
[IcebergIO] Use partition-aligned manifests for faster query pruning
io
java
#39158
opened Jun 29, 2026 by
atognolas
Contributor
Loading…
4 tasks
[IcebergIO] Use GroupByKey for bounded inputs to avoid OOM
io
java
Next Action: Reviewers
#39156
opened Jun 29, 2026 by
atognolas
Contributor
Loading…
3 tasks
[IcebergIO] Cache destination Row keys in AssignDestinationsAndPartitions
io
java
#39155
opened Jun 29, 2026 by
atognolas
Contributor
Loading…
3 tasks
[OpenTelemetry] Context propagation for Runner v1 and SimpleDoFnRunner
core
dataflow
java
Next Action: Reviewers
runners
#39152
opened Jun 29, 2026 by
stankiewicz
Contributor
Loading…
3 tasks
[OpenTelemetry] Add tracing support to KafkaIO
io
java
kafka
#39151
opened Jun 29, 2026 by
stankiewicz
Contributor
Loading…
3 tasks
[OpenTelemetry] Add tracing support to GCP PubsubIO
gcp
io
java
Next Action: Reviewers
#39150
opened Jun 29, 2026 by
stankiewicz
Contributor
Loading…
3 tasks
[OpenTelemetry] Add tracing support to GCP Spanner IO
gcp
io
java
Next Action: Reviewers
spanner
#39149
opened Jun 29, 2026 by
stankiewicz
Contributor
Loading…
3 tasks
Bump gradle-wrapper from 8.14.3 to 9.6.1
build
dependencies
Pull requests that update a dependency file
#39146
opened Jun 29, 2026 by
dependabot
Bot
Loading…
ci: pin GitHub Actions to full commit SHAs
build
Next Action: Reviewers
#39140
opened Jun 28, 2026 by
XananasX7
Loading…
Implement GroupByKey translation for Kafka Streams runner (#18479)
Next Action: Reviewers
runners
#39136
opened Jun 27, 2026 by
boy397
Loading…
3 tasks
Previous Next
ProTip!
Add no:assignee to see everything that’s not assigned.