Skip to content

Pull requests: apache/beam

New pull request New
107 Open 30,610 Closed
107 Open 30,610 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
Assigned to nobody Loading
Sort
Sort by
Newest Oldest Most commented Least commented Recently updated Least recently updated Best match
Most reactions
👍 👎 😄 🎉 😕 ❤️ 🚀 👀

Pull requests list

Add JVM arguments to fix hadoop-format tests on JDK 17+ hadoop io java
#39283 opened Jul 10, 2026 by tvalentyn Contributor Loading…
3 tasks
6
[wip] switch to newIncreamentalChangelogScan io java
#39282 opened Jul 10, 2026 by derrickaw Collaborator • Draft
3 tasks
1
Bump jackson version. build docker java Next Action: Reviewers
#39281 opened Jul 10, 2026 by tvalentyn Contributor Loading…
3 tasks
2
Bump httplib2 upper bound to <1.0.0 Next Action: Reviewers python
#39280 opened Jul 10, 2026 by tpwo Loading…
1 of 3 tasks
1
2
pass --add-opens to Spark PVR test JVM on Java 21 runners spark
#39278 opened Jul 10, 2026 by aIbrahiim Contributor Loading…
3 tasks
1
4
[GSoC 2026] Kafka Streams runner: Flatten support Next Action: Reviewers runners
#39273 opened Jul 9, 2026 by junaiddshaukat Contributor Loading…
7
Fix Flink runner tests on Java 21 flink Next Action: Reviewers runners
#39272 opened Jul 9, 2026 by aIbrahiim Contributor Loading…
3 tasks
1
8
IcerbergIO Load test and benchmarking build infra website
#39270 opened Jul 9, 2026 by Amar3tto Collaborator Loading…
3 tasks
3
[FnApi Java] Close named data stream multiplexers once no bundle is u… build extensions flink gcp infra java runners
#39255 opened Jul 9, 2026 by krishnamanchikalapudi Loading…
3 tasks
1
6
Support ACKNOWLEDGEMENT_MODE for JmsIO direct io java jms runners
#39253 opened Jul 9, 2026 by Abacn Contributor Loading…
3 tasks
2
9
[Iceberg] Validate AddFiles with UIT using BigQueryIO reads [WIP] io java
#39251 opened Jul 8, 2026 by ahmedabu98 Contributor • Draft
3 tasks
[Gemini] Add Java GeminiModelHandler class java Next Action: Reviewers
#39245 opened Jul 8, 2026 by jrmccluskey Contributor Loading…
3 tasks
1
16
Add Cloud Spanner Directed Reads support to SpannerIO gcp io java Next Action: Reviewers spanner
#39241 opened Jul 8, 2026 by ath-08 Loading…
11
[WIP] Add Dynamic Schema support to StorageWriteToBigQuery gcp io python
#39236 opened Jul 7, 2026 by jrmccluskey Contributor • Draft
3 tasks
1
fix xlang KafkaIO perf test expansion service Java version build
#39233 opened Jul 7, 2026 by aIbrahiim Contributor • Draft
3 tasks
1
1
[Docs] Add local Flink cluster guide for Python, update Flink version references Next Action: Author website
#39212 opened Jul 3, 2026 by Eliaaazzz Contributor • Draft
[#28420] Fix type inference for closures over local variables Next Action: Reviewers python
#39210 opened Jul 3, 2026 by lakshitbahl Loading…
3 tasks
15
Merge runtime type-checking wrappers into a single layer (BEAM-9489) Next Action: Reviewers python
#39206 opened Jul 2, 2026 by lakshitbahl Loading…
3 tasks
17
Support attributing BigQuery quota and billing to a custom GCP project (Python, Java, Go) gcp go io java Next Action: Reviewers python slow-review
#39203 opened Jul 2, 2026 by shahar1 Contributor Loading…
2 of 3 tasks
1
16
fix: add retries and URL encoding to Unmanaged Keys Audit workflow (#39188) Next Action: Reviewers
#39196 opened Jul 1, 2026 by raman118 Loading…
1
8
Remove previous workarounds for when super() could not be pickled on Py3 examples Next Action: Reviewers python
#39187 opened Jul 1, 2026 by ByteFlowing1337 Loading…
5
[GSoC 2026] Fixing the github action Unmanaged Service Account Keys build Next Action: Author
#39177 opened Jun 30, 2026 by HansMarcus01 Contributor Loading…
8
fix flakey fileiotest java Next Action: Reviewers
#39174 opened Jun 30, 2026 by derrickaw Collaborator Loading…
3 tasks
14
[Interactive Beam] Fix caching deadlock, wait race conditions, and stale graph in notebooks Next Action: Reviewers python runners
#39161 opened Jun 29, 2026 by ian-Liaozy Contributor Loading…
1 of 3 tasks
1
22
Add query_output_schema to ReadFromBigQuery for BEAM_ROW + query support gcp io Next Action: Reviewers python yaml
#39160 opened Jun 29, 2026 by nikitagrover19 Contributor Loading…
1 of 3 tasks
1
12
ProTip! Filter pull requests by the default branch with base:master.