-
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
[IcebergIO] Ensure compliance with table encryption
io
java
#39808
opened Aug 18, 2026 by
ahmedabu98
Contributor
Loading…
3 tasks
Remove nullness suppression in trigger implementation
core
runners
#39807
opened Aug 18, 2026 by
kennknowles
Member
Loading…
3 tasks
Refactor Java Secret classes to align with Python SDK
java
#39806
opened Aug 18, 2026 by
shunping
Collaborator
Loading…
Update SKILLs based on review practice
Next Action: Reviewers
#39805
opened Aug 18, 2026 by
Abacn
Contributor
Loading…
3 tasks
Portable Time type (Java + model changes)
java
model
Next Action: Reviewers
#39804
opened Aug 18, 2026 by
PDGGK
Contributor
Loading…
Fix stale broken cluster connection in CassandraIO (#39788)
cassandra
io
java
Next Action: Reviewers
#39803
opened Aug 18, 2026 by
sharan-malyala
Contributor
Loading…
[Python] Improve GroupByKey coder validation errors
python
runners
#39800
opened Aug 18, 2026 by
goutamadwant
Contributor
Loading…
3 tasks done
[runners-spark] Support stateful ParDo in the Structured Streaming batch runner
java
Next Action: Reviewers
runners
spark
#39793
opened Aug 17, 2026 by
f-loris
Loading…
fix: preserve duplicate same-timestamp elements in FlinkOrderedListState
flink
runners
#39783
opened Aug 17, 2026 by
waterWang
Loading…
Fix PubSub subscription path double-prefix in stale_cleaner (#39772)
infra
Next Action: Reviewers
#39778
opened Aug 17, 2026 by
waterWang
Loading…
Bound PGBKCVOperation precombine table by in-memory size (#39754)
python
runners
#39767
opened Aug 16, 2026 by
Dharshika-11
Loading…
fix: increase AVG MathContext precision from 10 to 34 to prevent BIGINT overflow and silent precision loss
extensions
java
Next Action: Reviewers
sql
#39765
opened Aug 16, 2026 by
waterWang
Loading…
Add Prism integration tests for Delta IO
build
delta
io
java
Next Action: Reviewers
#39764
opened Aug 16, 2026 by
goutamadwant
Contributor
Loading…
4 tasks done
normalize KinesisIO
aws
io
java
Next Action: Reviewers
python
yaml
#39763
opened Aug 15, 2026 by
aIbrahiim
Contributor
Loading…
3 tasks
Tag the Kafka write error output with the schema it actually emits
io
java
kafka
Next Action: Reviewers
#39760
opened Aug 15, 2026 by
PDGGK
Contributor
Loading…
Tag the TFRecord write error output with the schema it actually emits
java
Next Action: Reviewers
#39759
opened Aug 15, 2026 by
PDGGK
Contributor
Loading…
3 tasks done
Adds support for deading at a given Delta Lake version or timestamp
delta
io
java
Next Action: Reviewers
website
#39758
opened Aug 15, 2026 by
chamikaramj
Contributor
Loading…
3 tasks
Render ARRAY and ITERABLE fields that are not backed by a List
java
Next Action: Reviewers
#39750
opened Aug 14, 2026 by
PDGGK
Contributor
Loading…
[Java] Bound the Watch deduplication state with a timestamp cursor
java
Next Action: Reviewers
#39746
opened Aug 13, 2026 by
Eliaaazzz
Contributor
Loading…
4 tasks
Accept integral JSON values that a double represents exactly
java
Next Action: Reviewers
#39744
opened Aug 13, 2026 by
PDGGK
Contributor
Loading…
SnowflakeIO yaml
io
java
Next Action: Reviewers
python
yaml
#39742
opened Aug 13, 2026 by
Amar3tto
Collaborator
Loading…
3 tasks
Implement Vertex AI Model Monitoring v2
Next Action: Reviewers
python
#39738
opened Aug 12, 2026 by
jrmccluskey
Contributor
Loading…
3 tasks
Previous Next
ProTip!
Filter pull requests by the default branch with base:master.