-
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
Set getSession to synchronized to avoid race conditions
cassandra
io
java
#39817
opened Aug 19, 2026 by
sharan-malyala
Contributor
Loading…
Bump ClassGraph from 4.8.162 to 4.8.192
build
Next Action: Reviewers
#39815
opened Aug 19, 2026 by
kellen
Contributor
Loading…
3 tasks done
Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.22.41 to 1.22.43 in /sdks
dependencies
Pull requests that update a dependency file
go
#39812
opened Aug 19, 2026 by
dependabot
Bot
Loading…
[GSoC-273] Fix: Vulnerability in the action beam_infrastructure_users_permission
build
Next Action: Reviewers
#39811
opened Aug 19, 2026 by
HansMarcus01
Contributor
Loading…
[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
Next Action: Reviewers
runners
#39807
opened Aug 18, 2026 by
kennknowles
Member
Loading…
3 tasks
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
Previous Next
ProTip!
Adding no:label will show everything without a label.