-
Notifications
You must be signed in to change notification settings - Fork 4.7k
Pull requests: apache/beam
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
Update runner capability matrix
Next Action: Reviewers
website
#40106
opened Sep 11, 2026 by
Abacn
Contributor
Loading…
3 tasks
Revert "[Experimental] Use zstd compression in Docker builds"
build
Next Action: Reviewers
#40105
opened Sep 11, 2026 by
chamikaramj
Contributor
Loading…
AddFiles: CommitSchemaUnion
iceberg
Iceberg IO connector
io
java
Next Action: Reviewers
#40104
opened Sep 11, 2026 by
claudevdm
Collaborator
Loading…
3 tasks
[Spark] Make cancel() cancel the Spark jobs and stop only a session the runner created
Next Action: Author
runners
spark
#40103
opened Sep 11, 2026 by
tkaymak
Contributor
Loading…
Ensure 0 backlog is sent when finishing processing restrictions.
core
Next Action: Reviewers
runners
#40102
opened Sep 11, 2026 by
acrites
Contributor
Loading…
3 tasks
[Gemini] Add ExpireSnapshots maintenance operation to Iceberg IO
iceberg
Iceberg IO connector
io
java
Next Action: Reviewers
#40094
opened Sep 10, 2026 by
jrmccluskey
Contributor
Loading…
3 tasks
[Website] Add blog post on Python UnboundedSource and Watch
Next Action: Reviewers
website
#40091
opened Sep 10, 2026 by
Eliaaazzz
Contributor
Loading…
Warn on failed import of internal BQ client for easier debugging
gcp
io
Next Action: Reviewers
python
#40082
opened Sep 9, 2026 by
jrmccluskey
Contributor
Loading…
3 tasks
Portable tuple logical type
core
Next Action: Reviewers
python
#40081
opened Sep 9, 2026 by
Abacn
Contributor
Loading…
3 tasks
Implement Iceberg Side-Input Table Cache Integration with Fallback
io
java
Next Action: Reviewers
#40080
opened Sep 9, 2026 by
jrmccluskey
Contributor
Loading…
3 tasks
[Java] Fix TextIO gzip split test on Windows
core
java
Next Action: Reviewers
#40078
opened Sep 9, 2026 by
xujiantop-crypto
Loading…
[Java] Extract common timestamp output DoFn
core
java
Next Action: Reviewers
#40077
opened Sep 9, 2026 by
xujiantop-crypto
Loading…
Kafka Streams runner: add a flush marker payload variant
Next Action: Reviewers
runners
#40068
opened Sep 8, 2026 by
junaiddshaukat
Contributor
Loading…
[Python SDK] Add support for named data streams to provide bundle isolation
Next Action: Reviewers
python
runners
#40061
opened Sep 8, 2026 by
scwhittle
Contributor
Loading…
3 tasks
[Go] Fix pubsubio import of removed genproto package
gcp
go
io
Next Action: Reviewers
#40059
opened Sep 8, 2026 by
DiezNobach
Loading…
2 tasks done
Remove nullness suppression in PTransformReplacements
java
Next Action: Reviewers
#40045
opened Sep 7, 2026 by
nitinware
Contributor
Loading…
3 tasks done
Deprecate ParquetIO.withProjection (#20770)
io
java
Next Action: Reviewers
parquet
#40043
opened Sep 7, 2026 by
nitinware
Contributor
Loading…
normalize Spanner CDC
Next Action: Reviewers
python
yaml
#40040
opened Sep 7, 2026 by
aIbrahiim
Contributor
Loading…
3 tasks
[Iceberg CDC sink] Write deltas transform
io
java
#40031
opened Sep 5, 2026 by
ahmedabu98
Contributor
Loading…
3 tasks
[Iceberg CDC sink] Assign CDC keys
io
java
#40030
opened Sep 5, 2026 by
ahmedabu98
Contributor
Loading…
3 tasks
Temporary mitigation for Dataflow Managed Iceberg ITs
io
java
#40028
opened Sep 5, 2026 by
ahmedabu98
Contributor
Loading…
3 tasks
Previous Next
ProTip!
Exclude everything labeled
bug with -label:bug.