Skip to content

Pull requests: apache/beam

New pull request New
130 Open 29,416 Closed
130 Open 29,416 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

Fix ErrorProne BadInstanceof warnings and enable check globally build flink gcp io java jet runners samza spark twister2
#37753 opened Mar 3, 2026 by stankiewicz Loading…
3 tasks
1
Add default_pickle_library_override delegation to InteractiveRunner python runners
#37752 opened Mar 3, 2026 by praneetnadella Loading…
3 tasks
3
datastore: Same key in mutation batch gcp io java Next Action: Reviewers
#37751 opened Mar 3, 2026 by noseglid Loading…
3 tasks
2
[DebeziumIO] Implement startOffset for Kafka (#28248) go io java Next Action: Reviewers python
#37750 opened Mar 3, 2026 by tkaymak Loading…
4
[Dataflow Java Streaming] Ensure that OutOfMemoryError is propagated instead causing work item retry. dataflow runners
#37749 opened Mar 3, 2026 by scwhittle Loading…
3 tasks
3
Where a Throwable is being caught, take care to rethrow OutOfMemoryError core dataflow direct fn-execution java runners
#37748 opened Mar 3, 2026 by scwhittle Loading…
3 tasks
5
Add foundational API for Unbounded Sources in Python SDK io Next Action: Reviewers python
#37747 opened Mar 3, 2026 by shaheeramjad Loading…
2 of 3 tasks
2
[Dataflow Java Streaming] Ensure shared state is reset on OutOfMemoryError and not just Exceptions dataflow runners
#37746 opened Mar 3, 2026 by scwhittle Loading…
3 tasks
3
Error prone string concat when Preconditions is used cassandra dataflow flink fn-execution gcp io java kafka prism runners
#37745 opened Mar 3, 2026 by stankiewicz Loading…
3 tasks
9
Use JodaTime's static factories instead of the ambiguous constructors. aws clickhouse core dataflow direct elasticsearch examples extensions flink gcp hadoop io java model Next Action: Reviewers runners samza spark sql synthetic website
#37744 opened Mar 3, 2026 by stankiewicz Loading…
3 tasks
12
[release-2.72] Update go.mod go
#37742 opened Mar 3, 2026 by tvalentyn • Draft
3 tasks
2
Update go version. build go
#37741 opened Mar 3, 2026 by tvalentyn • Draft
3 tasks
1
Add more ParquetIo read options io java Next Action: Reviewers parquet
#37740 opened Mar 3, 2026 by claudevdm Loading…
3 tasks
6
Add Iceberg Quickstart page examples java Next Action: Reviewers python website
#37739 opened Mar 2, 2026 by ahmedabu98 Loading…
3
Cherrypick #37721 to release-2.72 build python
#37735 opened Mar 2, 2026 by Amar3tto Loading…
3 tasks
6
Bump com.gradleup.shadow:shadow-gradle-plugin from 8.3.8 to 9.3.2 build dependencies Pull requests that update a dependency file
#37734 opened Mar 2, 2026 by dependabot bot Loading…
1
Bump minimatch in /scripts/ci/pr-bot dependencies Pull requests that update a dependency file javascript Pull requests that update Javascript code Next Action: Reviewers
#37732 opened Mar 1, 2026 by dependabot bot Loading…
1
RedisIO support PCollection of <byte[], byte[]> io java Next Action: Reviewers redis
#37731 opened Mar 1, 2026 by MichaelGruschke Loading…
1 of 3 tasks
2
Bump minimatch from 3.1.2 to 3.1.5 in /sdks/typescript dependencies Pull requests that update a dependency file javascript Pull requests that update Javascript code Next Action: Reviewers typescript
#37729 opened Mar 1, 2026 by dependabot bot Loading…
1
Support inferring schemas from Python dataclasses python
#37728 opened Feb 28, 2026 by Abacn • Draft
3 tasks
1
1
Fix Python PostCommit Dependency Next Action: Reviewers python
#37725 opened Feb 27, 2026 by aIbrahiim Loading…
3 tasks
1
8
[Python] Ad BigQuery Change History source. gcp io python
#37724 opened Feb 27, 2026 by claudevdm Loading…
3 tasks
19
Adds bundleFinalizer support to Dataflow non-portable worker. core dataflow runners
#37723 opened Feb 26, 2026 by acrites Loading…
3 tasks
26
[SpannerIO] Add low-latency configuration in Spanner Change Streams with Heartbeat changes gcp io java Next Action: Reviewers spanner
#37718 opened Feb 26, 2026 by stankiewicz Loading…
3 tasks
6
Disable combiner lifting only for count triggers dataflow java Next Action: Reviewers runners
#37715 opened Feb 26, 2026 by reuvenlax Loading…
20
ProTip! Filter pull requests by the default branch with base:master.