Skip to content

Pull requests: apache/beam

New pull request New
142 Open 29,436 Closed
142 Open 29,436 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

[yaml] - add bigquery destination test python yaml
#37787 opened Mar 6, 2026 by derrickaw • Draft
3 tasks
1
[ErrorProne] Enable StaticAssignmentInConstructor check build dataflow direct hcatalog io java jms runners spark
#37786 opened Mar 6, 2026 by stankiewicz Loading…
3 tasks
2
[ErrorProne] Fix UnnecessaryMethodReference Check Findings build java Next Action: Reviewers
#37785 opened Mar 6, 2026 by stankiewicz Loading…
3 tasks
5
[ErrorProne] Enable UnsafeReflectiveConstructionCast check build extensions java
#37784 opened Mar 6, 2026 by stankiewicz Loading…
3 tasks
2
[ErrorProne] Enable UnnecessaryLongToIntConversion check build dataflow io java runners samza
#37783 opened Mar 6, 2026 by stankiewicz Loading…
3 tasks
5
Move FileIO close from RecordWriter to RecordWriterManager io java Next Action: Reviewers
#37782 opened Mar 6, 2026 by dejii Loading…
1 of 3 tasks
9
Bump xgrammar from 0.1.21 to 0.1.32 in /sdks/python/container/ml/py312 dependencies Pull requests that update a dependency file docker Next Action: Reviewers python
#37781 opened Mar 5, 2026 by dependabot bot Loading…
1
[Do not merge yet]Use hive-exec:core for compilation and and shaded for tests hcatalog io java Next Action: Reviewers website
#37780 opened Mar 5, 2026 by stankiewicz Loading…
3 tasks
7
[typescript] - pin minimatch ^3.1.4 Next Action: Reviewers typescript
#37778 opened Mar 5, 2026 by derrickaw Loading…
3 tasks
2
[ErrorProne] Enable JavaTimeDefaultTimeZone check build elasticsearch extensions gcp io java sql
#37775 opened Mar 5, 2026 by stankiewicz Loading…
3 tasks
15
[ErrorProne] Fix InvalidParam, InvalidInlineTag, InvalidBlockTag, and InvalidLink checks aws build core dataflow direct elasticsearch examples extensions flink fn-execution gcp hbase io java jdbc kafka prism rabbitmq runners samza spanner spark sql
#37773 opened Mar 4, 2026 by stankiewicz • Draft
3 tasks
3
[ErrorProne] Resolve Error Prone NonCanonicalType warnings across the codebase core dataflow examples flink gcp io java runners samza
#37772 opened Mar 4, 2026 by stankiewicz • Draft
3 tasks
3
[Error Prone] Fix Slf4j formatting errors and enable Slf4jFormatShouldBeConst check amqp aws bigtable build core direct elasticsearch extensions flink fn-execution gcp hbase healthcare io java jdbc jet jms kafka kudu mongodb runners samza solr spanner spark thrift
#37771 opened Mar 4, 2026 by stankiewicz • Draft
3 tasks
1
[ErrorProne] Fix UnusedVariable warnings across codebase build core dataflow direct elasticsearch extensions flink gcp hbase io java jdbc kafka kudu runners samza spanner sql
#37770 opened Mar 4, 2026 by stankiewicz Loading…
3 tasks
3
[ErrorProne] Enable LongDoubleConversion check build dataflow direct extensions gcp io java kafka runners sql
#37769 opened Mar 4, 2026 by stankiewicz • Draft
3 tasks
4
[ErrorProne] Fix UnnecessaryLambda Error Prone issues aws build dataflow io java kafka Next Action: Reviewers runners spark
#37765 opened Mar 4, 2026 by stankiewicz Loading…
3 tasks
9
[Java Portable SDK] Configure JVM so that it exits upon OutOfMemoryError originating in JVM. docker java Next Action: Reviewers
#37764 opened Mar 4, 2026 by scwhittle Loading…
3 tasks
2
[Dataflow Streaming] Add a pipeline option to skip input elements that cannot be decoded successfully dataflow java runners
#37762 opened Mar 4, 2026 by scwhittle Loading…
3 tasks
2
[ErrorProne] Enable BadImport ErrorProne check and fix violations build dataflow euphoria extensions fn-execution gcp io java runners spark
#37760 opened Mar 4, 2026 by stankiewicz Loading…
3 tasks
3
[ErrorProne] Fix EqualsGetClass warnings and enable Error Prone check aws build cassandra core dataflow examples extensions flink fn-execution gcp hadoop hbase healthcare io jackson java jdbc jet jms kryo protobuf redis runners samza spark sql
#37758 opened Mar 4, 2026 by stankiewicz Loading…
3 tasks
4
[ErrorProne] Fix MalformedInlineTag and enable check build euphoria extensions flink io java Next Action: Reviewers runners synthetic
#37755 opened Mar 3, 2026 by stankiewicz Loading…
3 tasks
4
[ErrorProne] Enable EmptyCatch Error Prone check and document ignored exceptions aws bigtable build examples extensions flink gcp healthcare io java Next Action: Reviewers prism runners
#37754 opened Mar 3, 2026 by stankiewicz Loading…
3 tasks
8
datastore: Same key in mutation batch gcp io java Next Action: Reviewers
#37751 opened Mar 3, 2026 by noseglid Loading…
2
[DebeziumIO] Implement startOffset & offset persistence for Kafka (#28248) go io java Next Action: Reviewers python
#37750 opened Mar 3, 2026 by tkaymak Loading…
9
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
3
ProTip! Adding no:label will show everything without a label.