-
Notifications
You must be signed in to change notification settings - Fork 4.4k
Pull requests: apache/beam
Author
Label
Projects
Milestones
Reviews
Assignee
Sort
Pull requests list
[DO NOT MERGE] Test spark version - 2.55.1
runners
spark
stale
#35998
opened Aug 28, 2025 by
DoctorCatCodes
Loading…
3 tasks
[Java]Fix Neo4jIO WriteUnwindWithResultsFn for Statistics Emission
io
java
Next Action: Reviewers
reassigned-reviewers
#35949
opened Aug 24, 2025 by
Suvrat1629
Loading…
1 of 3 tasks
[2/2] sdks/python: sink data with Milvus Search I/O connector
examples
Next Action: Reviewers
website
#35944
opened Aug 22, 2025 by
mohamedawnallah
Loading…
7 of 8 tasks
[Java]Fix NPE in UnboundedSolaceReader.getWatermark during disconnection (fixes #32660)
io
java
Next Action: Author
reassigned-reviewers
#35919
opened Aug 20, 2025 by
Suvrat1629
Loading…
3 tasks
fix: support vector features in PyOD anomaly detection batching logic
Next Action: Reviewers
python
stale
#35884
opened Aug 15, 2025 by
vijay-x-Raj
Loading…
Fix: Handle invalid bucket path warning in Beam Python SDK
Next Action: Author
python
#35744
opened Jul 30, 2025 by
yquaziii
Loading…
3 tasks
Adding time partitioning support for python storage write api
gcp
io
java
Next Action: Reviewers
python
reassigned-reviewers
#35737
opened Jul 30, 2025 by
TanuSharma2511
Loading…
3 tasks
[1/2] sdks/python: sink data with Milvus Search I/O connector
examples
python
#35708
opened Jul 27, 2025 by
mohamedawnallah
Loading…
6 of 8 tasks
Added Filter and Projection Pushdown support to ParquetIO and Beam SQL's ParquetTable
aws
bigtable
build
core
dataflow
direct
docker
examples
extensions
flink
fn-execution
gcp
go
hadoop
hbase
hcatalog
healthcare
infra
io
java
jdbc
jet
jms
kafka
learning
local
model
mongodb
mqtt
Next Action: Reviewers
parquet
prism
protobuf
python
runners
samza
sketching
spanner
spark
sql
synthetic
tests
thrift
twister2
typescript
vendor
website
yaml
#35589
opened Jul 15, 2025 by
talatuyarer
Loading…
3 tasks
[Iceberg SQL] Add iceberg CDC table
extensions
java
sql
#35562
opened Jul 10, 2025 by
ahmedabu98
•
Draft
Create new SubProject to not depend on Dataflow in Kafka
build
io
java
kafka
Next Action: Author
#35452
opened Jun 26, 2025 by
fozzie15
Loading…
3 tasks
[IcebergIO] Change writer open/close logs to debug
io
java
Next Action: Author
#35240
opened Jun 11, 2025 by
ahmedabu98
•
Draft
[OpenTelemetry] Add an experiment to enable the instrumentation agent in Java's portability harness
build
docker
java
Next Action: Author
#35227
opened Jun 10, 2025 by
sjvanrossum
Loading…
3 tasks
Add BigQuery Storage Read API Enrichment Handler
examples
Next Action: Author
python
reassigned-reviewers
website
#35197
opened Jun 7, 2025 by
pandasanjay
Loading…
3 tasks
Fix nullness errors in SimpleDoFnRunner and DoFnInvoker
core
io
java
Next Action: Reviewers
runners
#35029
opened May 22, 2025 by
kennknowles
Loading…
3 tasks done
Add Kafka to Kafka RAW example pipeline configuration
Next Action: Author
python
reassigned-reviewers
yaml
#34992
opened May 18, 2025 by
Ashfaqbs
Loading…
[Gradle] Refactor Java toolchain selection using Gradle toolchain management
build
dataflow
docker
examples
extensions
go
hcatalog
infra
io
java
kotlin
Next Action: Reviewers
portability
prism
python
runners
spark
sql
stale
website
#34915
opened May 12, 2025 by
sjvanrossum
•
Draft
3 tasks
Request to use BASIC enum when calling tables.get() in BigQuery #34075
gcp
io
python
yaml
#34249
opened Mar 11, 2025 by
tamannakakkar93
•
Draft
[BEAM-6394] Add support to write protobuf data using ProtoParquetReader
io
java
Next Action: Reviewers
parquet
reassigned-reviewers
#34063
opened Feb 25, 2025 by
cyberbeam524
Loading…
3 tasks
[IcebergIO] load tests
build
io
java
Next Action: Author
synthetic
#33728
opened Jan 22, 2025 by
ahmedabu98
•
Draft
create helper function
Next Action: Reviewers
pinned
python
#26225
opened Apr 11, 2023 by
smeet07
Loading…
1 of 3 tasks
Previous Next
ProTip!
Exclude everything labeled
bug with -label:bug.