-
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
[Flink] Bound SDF self-checkpoint residual state on the portable runner
flink
fn-execution
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…
Add "-Pjava21Home" to stage docker step in build_release_candidate workflow
build
Next Action: Reviewers
#39181
opened Jun 30, 2026 by
Abacn
Contributor
Loading…
3 tasks
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…
Implement GroupByKey translation for Kafka Streams runner (#18479)
Next Action: Reviewers
runners
#39136
opened Jun 27, 2026 by
boy397
Loading…
3 tasks
Avoid output inside try-catch in Java IO
gcp
healthcare
io
java
Next Action: Reviewers
#39124
opened Jun 26, 2026 by
Aryankn29
Loading…
Previous Next
ProTip!
no:milestone will show everything without a milestone.