-
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
Add metric for Kafka offset commit failures
io
java
kafka
Next Action: Reviewers
#38889
opened Jun 10, 2026 by
Kriti-dev07
Loading…
[IcebergIO] Improve TableCache
io
java
Next Action: Reviewers
#38882
opened Jun 9, 2026 by
ahmedabu98
Contributor
Loading…
3 tasks
[wip] spotless
aws
bigtable
build
cassandra
clickhouse
core
dataflow
direct
elasticsearch
euphoria
examples
extensions
flink
fn-execution
gcp
hadoop
hcatalog
healthcare
infra
io
java
jdbc
jms
kafka
local
mongodb
parquet
portability
prism
protobuf
rabbitmq
runners
spanner
spark
sql
synthetic
tests
thrift
twister2
xml
zetasketch
[SQL] Support positional parameters
extensions
java
Next Action: Reviewers
sql
#38880
opened Jun 9, 2026 by
Abacn
Contributor
Loading…
3 tasks
update iceberg add files parameters
Next Action: Reviewers
python
yaml
#38879
opened Jun 9, 2026 by
derrickaw
Collaborator
Loading…
3 tasks
Fix wordcount_rust requirements.txt and documentation
examples
Next Action: Reviewers
python
#38877
opened Jun 9, 2026 by
jrmccluskey
Contributor
Loading…
3 tasks
[IcebergIO] Support TableIdentifiers with special characters
io
java
#38876
opened Jun 9, 2026 by
ahmedabu98
Contributor
Loading…
3 tasks
Implement BeamFileSystemClient for Delta Lake connector
delta
io
java
#38873
opened Jun 9, 2026 by
joaohmalves
Loading…
1 of 3 tasks
Fix Xlang IO Direct installGcpTest uv cache lock
build
Next Action: Reviewers
#38862
opened Jun 9, 2026 by
aIbrahiim
Contributor
Loading…
3 tasks
Allow strongly-consistent schema updates in BigQueryIO
gcp
io
java
Next Action: Reviewers
#38854
opened Jun 9, 2026 by
reuvenlax
Contributor
Loading…
pin pip>=26.1
docker
Next Action: Reviewers
python
#38852
opened Jun 8, 2026 by
derrickaw
Collaborator
Loading…
3 tasks
Previous Next
ProTip!
Add no:assignee to see everything that’s not assigned.