Pull requests · apache/beam

Added Criteo TFT fill_in_missing helper python

#39011 opened Jun 17, 2026 by lalitx17 Contributor Loading…

8

Validate Project of staging bucket gcp io python

#39008 opened Jun 17, 2026 by tarun-google Contributor Loading…

11

Fix The PreCommit Python ML tests with ML deps installed job Next Action: Reviewers python

#39007 opened Jun 17, 2026 by aIbrahiim Contributor Loading…

3 tasks

1 6

Drop Flink 1.17,1.18 support build examples flink go python runners typescript

#39006 opened Jun 17, 2026 by Abacn Contributor Loading…

3 tasks

6

Add retry filter support to the Java Remote RetryHandler java

#39004 opened Jun 17, 2026 by jrmccluskey Contributor Loading…

3 tasks

6

Bump vllm from 0.10.1.1 to 0.23.0 in /sdks/python/container/ml/py312 dependencies Pull requests that update a dependency file docker python

#39003 opened Jun 17, 2026 by dependabot Bot Loading…

1

Bump vllm from 0.10.1.1 to 0.23.0 in /sdks/python/container/ml/py310 dependencies Pull requests that update a dependency file docker python

#39002 opened Jun 17, 2026 by dependabot Bot Loading…

1

[GSOC 2026] Adding logic to validate and generate an error if there are key…

#38992 opened Jun 16, 2026 by HansMarcus01 Contributor Loading…

7

[Dataflow Streaming] Access state/timerinternals via StepContext core dataflow flink runners

#38991 opened Jun 16, 2026 by arunpandianp Contributor Loading…

10

Handle multi-key bundles in side-input runner dataflow Next Action: Reviewers runners

#38988 opened Jun 16, 2026 by reuvenlax Contributor Loading…

23

[GSoC 2026] Kafka Streams runner — WatermarkManager part 2: wire into ExecutableStageProcessor Next Action: Reviewers runners

#38987 opened Jun 16, 2026 by junaiddshaukat Contributor Loading…

9

Fix CloudML TFT driver install avoiding pip ResolutionTooDeep python

#38986 opened Jun 16, 2026 by aIbrahiim Contributor • Draft

3 tasks

4

[Python] Optimize BigQuery copy jobs in file loads using multi-source copy gcp io python

#38983 opened Jun 16, 2026 by stankiewicz Contributor Loading…

3 tasks

1 14

Add Flink 2.2.1 runner support build flink Next Action: Reviewers python runners typescript website

#38980 opened Jun 16, 2026 by mananmangal Loading…

3 tasks

1 14

Add unit tests to Go harness package (issue #21386) go Next Action: Reviewers

#38979 opened Jun 16, 2026 by weibangpeng Loading…

6

Bump starlette from 1.2.1 to 1.3.1 in /sdks/python/container/ml/py311 dependencies Pull requests that update a dependency file docker python

#38975 opened Jun 16, 2026 by dependabot Bot Loading…

1

Roll forward io expansion service to Java17 build io java Next Action: Reviewers

#38974 opened Jun 15, 2026 by derrickaw Collaborator Loading…

3 tasks

14

Bump cryptography from 47.0.0 to 48.0.1 in /sdks/python/container/py312 dependencies Pull requests that update a dependency file docker python

#38973 opened Jun 15, 2026 by dependabot Bot Loading…

1

[aws2] Fix flaky SqsIOWriteBatchesTest timeout tests (#38946) aws io java Next Action: Reviewers

#38971 opened Jun 15, 2026 by tkaymak Contributor Loading…

1 13

[Website] Update Python version compatibility table Next Action: Reviewers website

#38969 opened Jun 15, 2026 by jrmccluskey Contributor Loading…

3 tasks

4

[mqtt] Add Python Xlang Messaging PostCommit with MQTT integration tests build io python

#38966 opened Jun 15, 2026 by tkaymak Contributor Loading…

13

Bump distlib from 0.4.2 to 0.4.3 in /sdks/python dependencies Pull requests that update a dependency file python

#38959 opened Jun 15, 2026 by dependabot Bot Loading…

1

Bump torch from 2.7.1 to 2.12.0 in /sdks/python/container/ml/py310 dependencies Pull requests that update a dependency file docker python

#38956 opened Jun 13, 2026 by dependabot Bot Loading…

1

Adds a Dataflow integration test suite for Delta Lake build delta io java Next Action: Reviewers

#38954 opened Jun 12, 2026 by chamikaramj Contributor Loading…

3 tasks

1 15

Bump pyo3 from 0.27.2 to 0.29.0 in /sdks/python/apache_beam/examples/wordcount_rust/word_processing dependencies Pull requests that update a dependency file examples python rust Pull requests that update rust code

#38953 opened Jun 12, 2026 by dependabot Bot Loading…

1