Skip to content

Pull requests: apache/beam

New pull request New
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

Fix: Replace deprecated DataFrame.applymap with map for compatibility python runners
#33532 opened Jan 8, 2025 by Pushkar3119 Loading…
2
[Managed Iceberg] unbounded source build io java model
#33504 opened Jan 6, 2025 by ahmedabu98 Loading…
1
56
Kafka add counters v1 uw2 core dataflow gcp io java kafka model Next Action: Reviewers runners slow-review
#33503 opened Jan 6, 2025 by Naireen Loading…
3 tasks
94
chore: update to use versions for LTS 8 build stale
#33451 opened Dec 26, 2024 by ldetmer • Draft
3 tasks
2
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…
1
[docs] Add new Python multi-lang quickstart using the SchemaTransform framework Next Action: Author website
#33360 opened Dec 11, 2024 by ahmedabu98 Loading…
1
17
Tour of Beam: update GroupByKey example learning Next Action: Reviewers
#33242 opened Nov 27, 2024 by thread-sleep Loading…
3 tasks
20
Adding Google Storage Requester pays feature to Golang SDK. go io Next Action: Author
#33236 opened Nov 27, 2024 by LeoCBS Loading…
1
26
Avoid holding data elements alive via stack frame gc roots. java
#33086 opened Nov 12, 2024 by scwhittle Loading…
3 tasks
7
Read RabbitMQ messages with headers containing nested objects io java Next Action: Reviewers rabbitmq
#33072 opened Nov 11, 2024 by jonomorris Loading…
3 tasks
1
26
ignore overridden setters and getters in JavaBeanSchema java
#33052 opened Nov 8, 2024 by tilgalas Loading…
4
[KafkaIO] Decouple consumer threads from harness threads io java kafka
#32986 opened Oct 31, 2024 by sjvanrossum • Draft
3 tasks
@scwhittle
26
add generics support to AutoValueUtils helpers java Next Action: Reviewers slow-review
#32977 opened Oct 30, 2024 by tilgalas Loading…
18
Update CHANGES.md to include streaming NPE issue Next Action: Author
#32793 opened Oct 15, 2024 by TongruiLi Loading…
3 tasks
22
Add portable Mqtt source and sink transforms io java mqtt Next Action: Reviewers slow-review
#32385 opened Aug 30, 2024 by ahmedabu98 Loading…
1
22
BigQueryIO uniformize direct and export reads examples extensions gcp io java Next Action: Reviewers zetasketch
#32360 opened Aug 29, 2024 by RustedBones Loading…
1
50
Support writing to Pubsub with ordering key; Add PubsubMessage SchemaCoder dataflow gcp io java Next Action: Reviewers runners
#31608 opened Jun 15, 2024 by ahmedabu98 Loading…
1
94
Implement a Top partitioner python
#29106 opened Oct 23, 2023 by hjtran Loading…
19
Fix flaky test suite beam_PostCommit_XVR_Direct Next Action: Author python
#28973 opened Oct 12, 2023 by chamikaramj Loading…
3 tasks
20
Replace StorageV1 client with GCS client - Draft examples gcp io python
#28733 opened Sep 29, 2023 by BjornPrime • Draft
3 tasks
18
create helper function Next Action: Reviewers pinned python
#26225 opened Apr 11, 2023 by smeet07 Loading…
1 of 3 tasks
71
Backlog metrics do not showing up in FlinkRunner flink runners
#25554 opened Feb 19, 2023 by talatuyarer Loading…
22
ProTip! Add no:assignee to see everything that’s not assigned.