Skip to content

Pull requests: apache/beam

New pull request New
101 Open 26,736 Closed
101 Open 26,736 Closed
Author
Filter by author
Loading
Label
Filter by label
Loading
Use alt + click/return to exclude labels
or ⇧ + click/return for logical OR
Projects
Filter by project
Loading
Milestones
Filter by milestone
Loading
Reviews
Filter by reviews
No reviews Review required Approved review Changes requested
Assignee
Filter by who’s assigned
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

Fix version on the master build
#34371 opened Mar 20, 2025 by liferoad Loading…
3 tasks
1
fix the check on the 2.64 release branch build
#34370 opened Mar 20, 2025 by liferoad Loading…
3 tasks
1
remove private ipv6 check dataflow runners
#34368 opened Mar 20, 2025 by m-trieu Loading…
3 tasks
1
add graceful restart mechanism for GetWorkStream to prevent DEADLINE_… dataflow runners
#34367 opened Mar 20, 2025 by m-trieu Loading…
3 tasks
1
Fix MongoDB connector by adding codec options io python
#34365 opened Mar 20, 2025 by haperski • Draft
1 of 3 tasks
1
Safeguard boundedtrie result dataflow runners
#34363 opened Mar 20, 2025 by rohitsinha54 Loading…
3 tasks
4
Mention __init__.py, which is customary for packages. website
#34362 opened Mar 20, 2025 by tvalentyn Loading…
3 tasks
2
ML benchmark pipelines build infra python website
#34361 opened Mar 20, 2025 by Amar3tto Loading…
3 tasks
4
Bump github.com/aws/aws-sdk-go-v2/config from 1.29.6 to 1.29.9 in /sdks dependencies Pull requests that update a dependency file go Next Action: Reviewers
#34357 opened Mar 20, 2025 by dependabot bot Loading…
1
[Dataflow Streaming] Optimize serialization of small commits dataflow runners
#34355 opened Mar 20, 2025 by arunpandianp Loading…
5
Create a varint32 coder and used it for RowCoder build io python
#34354 opened Mar 20, 2025 by Abacn Loading…
3 tasks
1
3
Enabling AWS STS credentials refresh for federated authentication aws io java
#34353 opened Mar 19, 2025 by prodriguezdefino • Draft
3 tasks
Preserve pane index through reshuffle. go prism python runners
#34348 opened Mar 19, 2025 by claudevdm • Draft
3 tasks
[Java]Add Map Type Support to JsonToRow Transformer java Next Action: Reviewers
#34347 opened Mar 19, 2025 by Suvrat1629 Loading…
1 of 3 tasks
3
Add docs for yaml dependencies. python website yaml
#34345 opened Mar 19, 2025 by robertwb Loading…
3 tasks
3
Bump github.com/aws/aws-sdk-go-v2/service/s3 from 1.77.0 to 1.78.2 in /sdks dependencies Pull requests that update a dependency file go
#34341 opened Mar 19, 2025 by dependabot bot Loading…
1
[KafkaIO] Improve caching in backlog estimation and processing io java kafka Next Action: Reviewers
#34331 opened Mar 18, 2025 by sjvanrossum Loading…
3 tasks
1
Update pypi documentation 30145 python
#34329 opened Mar 18, 2025 by rakeshcusat Loading…
1 of 3 tasks
1
Key by paneindex and reshuffle before loading files. gcp io Next Action: Reviewers python
#34324 opened Mar 17, 2025 by claudevdm Loading…
3 tasks
10
Add 3 examples in playground SQL transform, schema transform and Composite Combine examples java Next Action: Reviewers
#34322 opened Mar 17, 2025 by razvanculea Loading…
3
Fix typo in BigQuery Python Documentation gcp io Next Action: Reviewers python
#34317 opened Mar 16, 2025 by AaronTrelstad Loading…
1
1
[Java] Add Gauge Metric Extraction to DataflowMetrics dataflow Next Action: Reviewers runners
#34307 opened Mar 15, 2025 by Suvrat1629 Loading…
1 of 3 tasks
1
6
Add STRING format to ReadFromKafka schema transform. io java kafka Next Action: Reviewers
#34302 opened Mar 14, 2025 by robertwb Loading…
3 tasks
5
[Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) io java Next Action: Reviewers
#34296 opened Mar 14, 2025 by Suvrat1629 Loading…
1 of 3 tasks
1
2
do not block other threads from health checking if a stream is blocked dataflow Next Action: Reviewers runners
#34283 opened Mar 13, 2025 by m-trieu Loading…
3 tasks
4
ProTip! Add no:assignee to see everything that’s not assigned.