Skip to content

Pull requests: apache/beam

New pull request New
Clear current search query, filters, and sorts
97 Open 26,617 Closed
97 Open 26,617 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

ignore overridden setters and getters in JavaBeanSchema java
#33052 opened Nov 8, 2024 by tilgalas Loading… updated Jan 7, 2025
4
[KafkaIO] Decouple consumer threads from harness threads io java kafka
#32986 opened Oct 31, 2024 by sjvanrossum • Draft updated Jan 9, 2025
3 tasks
@scwhittle
26
Fix: Replace deprecated DataFrame.applymap with map for compatibility python runners
#33532 opened Jan 8, 2025 by Pushkar3119 Loading… updated Jan 13, 2025
2
[WIP] [Do not Merge] [Dataflow Streaming] Support for using virtual harness threads build dataflow runners
#33543 opened Jan 8, 2025 by arunpandianp Loading… updated Jan 13, 2025
3 tasks
3
Backlog metrics do not showing up in FlinkRunner flink runners
#25554 opened Feb 19, 2023 by talatuyarer Loading… updated Jan 14, 2025
22
Handle missing tables more gracefully. gcp io python
#33610 opened Jan 15, 2025 by bmrosen Loading… updated Jan 15, 2025
3 tasks
1
Add support for Iceberg table identifiers with special characters build io java Next Action: Reviewers
#33648 opened Jan 17, 2025 by regadas Loading… updated Jan 21, 2025
3 tasks
7
[Dataflow Streaming] Use concurrent queue for commit queue aws dataflow io java runners
#33690 opened Jan 21, 2025 by arunpandianp • Draft updated Jan 23, 2025
3
[Dataflow Streaming] Cache StateNamespace encoded keys using SoftReference core runners
#33689 opened Jan 21, 2025 by arunpandianp Loading… updated Jan 23, 2025
6
Bump net.researchgate.release from 2.8.1 to 3.1.0 build dependencies Pull requests that update a dependency file
#33446 opened Dec 24, 2024 by dependabot bot Loading… updated Jan 23, 2025
1
Newtypes python
#33766 opened Jan 25, 2025 by hjtran • Draft updated Jan 25, 2025
3 tasks
init dummy file python
#33767 opened Jan 25, 2025 by hjtran • Draft updated Jan 25, 2025
3 tasks
1
Revert "Updated the python dependencies (targeted for Beam 2.63.0)" build docker python
#33774 opened Jan 27, 2025 by Abacn • Draft updated Jan 27, 2025
4
Update CHANGES.md to include streaming NPE issue Next Action: Author
#32793 opened Oct 15, 2024 by TongruiLi Loading… updated Jan 28, 2025
3 tasks
22
Support sharding in WriteToFiles (tested for to_csv) io Next Action: Author python
#33612 opened Jan 15, 2025 by langner Loading… updated Jan 29, 2025
7
Fix flaky test suite beam_PostCommit_XVR_Direct Next Action: Author python
#28973 opened Oct 12, 2023 by chamikaramj Loading… updated Jan 31, 2025
3 tasks
20
DRAFT: Deploy Prism on Kubernetes docker go
#33568 opened Jan 13, 2025 by damondouglas • Draft updated Jan 31, 2025
3 tasks
create helper function Next Action: Reviewers pinned python
#26225 opened Apr 11, 2023 by smeet07 Loading… updated Feb 1, 2025
1 of 3 tasks
71
[docs] Add new Python multi-lang quickstart using the SchemaTransform framework Next Action: Author website
#33360 opened Dec 11, 2024 by ahmedabu98 Loading… updated Feb 4, 2025
1
17
Remove type coercion of FinalizeWrite in iobase.py io Next Action: Author python
#33614 opened Jan 16, 2025 by liaopeiyuan Loading… updated Feb 4, 2025
3 tasks done
8
Remove type suppressions from MetricsPusher and MetricsSink core extensions java runners
#33918 opened Feb 7, 2025 by kennknowles Loading… updated Feb 7, 2025
3 tasks done
1
Adding credentials option to PubsubMessageMatcher gcp io python
#33958 opened Feb 11, 2025 by mchinbox Loading… updated Feb 11, 2025
3 tasks
1
Upgrade to hive 4.0.1 build extensions hcatalog io java Next Action: Reviewers slow-review sql
#33750 opened Jan 23, 2025 by Abacn • Draft updated Feb 12, 2025
3 tasks
1
11
Upgrade Kafka client version to 3.7.0 build io java kafka
#33960 opened Feb 12, 2025 by tomstepp Loading… updated Feb 12, 2025
4
[IcebergIO] load tests build
#33728 opened Jan 22, 2025 by ahmedabu98 • Draft updated Feb 14, 2025
ProTip! Follow long discussions with comments:>50.