- Notifications
You must be signed in to change notification settings - Fork4.3k
Pull requests: apache/beam
Author
Label
Projects
Milestones
Reviews
Assignee
Assigned to nobodyLoading
Sort
Pull requests list
Fix pandas doctests sensitive to NumpyExtensionArray formatting. Next Action: Reviewers python
#34336 openedMar 18, 2025 byrobertwbLoading…
3 tasks
Remove cancelled tasks from ReadOperation queue when shutting down dataflow Next Action: Reviewers runners
#34335 openedMar 18, 2025 bydamccormLoading…
3 tasks
Kafka Consumer Group Properties extensions java sql
#34334 openedMar 18, 2025 bytalatuyarerLoading…
3 tasks
[KafkaIO] Improve caching in backlog estimation and processing io java kafka Next Action: Reviewers
#34331 openedMar 18, 2025 bysjvanrossumLoading…
3 tasks
Enable xlang access for SQS read functionality aws io java Next Action: Reviewers
#34327 openedMar 17, 2025 byprodriguezdefinoLoading…
3 tasks
Key by paneindex and reshuffle before loading files. gcp io Next Action: Reviewers python
#34324 openedMar 17, 2025 byclaudevdmLoading…
3 tasks
Aggregation option in Kinesis Writer Python sdk aws io java Next Action: Reviewers python
#34323 openedMar 17, 2025 byNakachi-SLoading…
2 of 3 tasks
Add 3 examples in playground SQL transform, schema transform and Composite Combine examples java Next Action: Reviewers
#34322 openedMar 17, 2025 byrazvanculeaLoading…
Fix typo in BigQuery Python Documentation gcp io Next Action: Reviewers python
#34317 openedMar 16, 2025 byAaronTrelstadLoading…
Add an experiment named enableLineageRollup which when passed to Java… java
#34312 openedMar 16, 2025 byrohitsinha54Loading…
3 tasks
[Java] Add Gauge Metric Extraction to DataflowMetrics dataflow Next Action: Reviewers runners
#34307 openedMar 15, 2025 bySuvrat1629Loading…
1 of 3 tasks
Add STRING format to ReadFromKafka schema transform. io java kafka Next Action: Reviewers
#34302 openedMar 14, 2025 byrobertwbLoading…
3 tasks
[Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660) io java Next Action: Reviewers
#34296 openedMar 14, 2025 bySuvrat1629Loading…
1 of 3 tasks
Revert Skip BoundedTrie on Dataflow till service is have BoundedTrie … dataflow Next Action: Reviewers runners
#34294 openedMar 14, 2025 byrohitsinha54Loading…
3 tasks
Bump google.golang.org/api from 0.221.0 to 0.226.0 in /sdks dependenciesPull requests that update a dependency file go Next Action: Reviewers
#34293 openedMar 14, 2025 bydependabotbotLoading…
[Dataflow Streaming] WindmillTimerInternals: Use a single map to store timer data + liveness dataflow runners
#34292 openedMar 14, 2025 byarunpandianpLoading…
do not block other threads from health checking if a stream is blocked dataflow Next Action: Reviewers runners
#34283 openedMar 13, 2025 bym-trieuLoading…
3 tasks
Fix programming guide python reference for combining pcollection into a single value Next Action: Reviewers website
#34282 openedMar 13, 2025 byjbandoroLoading…
3 tasks
Update docstring to clarify numShards=0 doesn't neccessarily enable autosharding java
#34280 openedMar 13, 2025 byNaireenLoading…
3 tasks
Making setServiceFactory public in SpannerConfig for Failure injection testing in Dataflow templates gcp io java spanner
#34271 openedMar 13, 2025 bydarshan-sjLoading…
3 tasks
Fix Republish Released Docker Images workflow build Next Action: Reviewers
#34268 openedMar 13, 2025 byakashorabekLoading…
3 tasks
Bump golang.org/x/net from 0.23.0 to 0.36.0 in /learning/katas/go dependenciesPull requests that update a dependency file go learning Next Action: Reviewers
#34267 openedMar 12, 2025 bydependabotbotLoading…
ProTip! Mix and match filters to narrow down what you’re looking for.