apache/beam
View on GitHubApache Beam is a unified programming model for Batch and Streaming data processing.
- Stars
- 8.7k
- Forks
- 4.7k
- Open beginner issues
- 0
- Indexed issues
- 3.8k
- Avg merge
- 2d 9h
- Merged PRs (30d)
- 202
- Dominant language
- Java
- License
- Apache-2.0
- Last GitHub push
- Sep 14, 2026
- Latest indexed
- Sep 14, 2026
- Contributing guide
- Contributing guide
- Code of conduct
- Code of conduct
- Beginner labels
- good first issue
-
Make Python side input tags always key, value pairs instead of depending in index suffixed tag names Opencore improvement P3 python
apache/beam#20136 · 0 comments · 0 reactions · 0 assignees ·
-
avro improvement io java P3
apache/beam#20138 · 0 comments · 0 reactions · 0 assignees ·
-
Apache Beam/Dataflow flowed a CalledProcessError with beam.Pipeline("DataflowRunner", options=opts) Openbug core dataflow P3 python runners
apache/beam#20140 · 0 comments · 0 reactions · 0 assignees ·
-
build flink P3 runners tests
apache/beam#20141 · 0 comments · 0 reactions · 0 assignees ·
-
bug core dataflow P3 python runners
apache/beam#20142 · 0 comments · 0 reactions · 0 assignees ·
-
bug flink P3 runners
apache/beam#20143 · 0 comments · 0 reactions · 0 assignees ·
-
core harness improvement P3 python
apache/beam#20144 · 0 comments · 0 reactions · 0 assignees ·
-
bug core P3 python
apache/beam#20145 · 0 comments · 0 reactions · 0 assignees ·
-
flink P3 portability runners spark wish
-
flink P3 portability runners spark sub-task
apache/beam#20149 · 0 comments · 0 reactions · 0 assignees ·
-
P3 portability runners spark sub-task
-
dataflow improvement io java kinesis P3 runners
apache/beam#20152 · 0 comments · 0 reactions · 0 assignees ·
-
bug gcp io java P3
apache/beam#20155 · 0 comments · 0 reactions · 0 assignees ·
-
core improvement P3 python
apache/beam#20157 · 0 comments · 0 reactions · 0 assignees ·
-
gcp improvement io java P3
apache/beam#20160 · 0 comments · 0 reactions · 0 assignees ·
-
bug P3 website
apache/beam#20161 · 0 comments · 0 reactions · 0 assignees ·
-
bug core P3 python
apache/beam#20162 · 0 comments · 0 reactions · 0 assignees ·
-
core new feature P3 python
apache/beam#20163 · 0 comments · 0 reactions · 0 assignees ·
-
bug core P3 python
apache/beam#20165 · 0 comments · 0 reactions · 0 assignees ·
-
bug core dataflow P3 python runners
apache/beam#20166 · 0 comments · 0 reactions · 0 assignees ·
-
bug flink P3 runners spark
apache/beam#20169 · 0 comments · 0 reactions · 0 assignees ·
-
bug core P3 python
apache/beam#20170 · 0 comments · 0 reactions · 0 assignees ·
-
bug gcp io P3 python
apache/beam#20172 · 0 comments · 0 reactions · 0 assignees ·
-
core improvement P3 python
apache/beam#20174 · 0 comments · 0 reactions · 0 assignees ·
-
failing test P3 tests
apache/beam#20175 · 0 comments · 0 reactions · 0 assignees ·
-
new feature P3 portability runners spark
apache/beam#20177 · 0 comments · 0 reactions · 0 assignees ·
-
dsl improvement P3 sql
apache/beam#20178 · 0 comments · 0 reactions · 0 assignees ·
-
new feature P3 runners spark
apache/beam#20179 · 0 comments · 0 reactions · 0 assignees ·
-
bug gcp io P3 python
apache/beam#20180 · 0 comments · 0 reactions · 0 assignees ·
-
flink improvement P3 portability runners
apache/beam#20182 · 0 comments · 0 reactions · 0 assignees ·
-
improvement P3 portability runners spark
apache/beam#20183 · 0 comments · 0 reactions · 0 assignees ·
-
improvement P3 website
apache/beam#20184 · 0 comments · 0 reactions · 0 assignees ·
-
dsl P3 sql task
apache/beam#20186 · 0 comments · 0 reactions · 0 assignees ·
-
Reduce logging related to ratelimitExceeded error for BQ sink when performing streaming inserts Opengcp improvement io java P3
apache/beam#20187 · 0 comments · 0 reactions · 0 assignees ·
-
ideas io new feature P3
apache/beam#20188 · 0 comments · 0 reactions · 0 assignees ·
-
P2 portability spark
apache/beam#20189 · 0 comments · 0 reactions · 0 assignees ·
-
bug core P3 python
apache/beam#20190 · 0 comments · 0 reactions · 0 assignees ·
-
bug core P3 python
apache/beam#20191 · 0 comments · 0 reactions · 0 assignees ·
-
improvement P3 portability runners spark
apache/beam#20192 · 0 comments · 0 reactions · 0 assignees ·
-
bug core P3 python windows
apache/beam#20195 · 0 comments · 0 reactions · 0 assignees ·
-
go improvement P3
apache/beam#20196 · 0 comments · 0 reactions · 0 assignees ·
-
bug core java P3
apache/beam#20197 · 0 comments · 0 reactions · 0 assignees ·
-
core improvement java P3
apache/beam#20198 · 0 comments · 0 reactions · 0 assignees ·
-
bug core java P3
apache/beam#20199 · 0 comments · 0 reactions · 0 assignees ·
-
core improvement java P3
apache/beam#20200 · 0 comments · 0 reactions · 0 assignees ·
-
core java new feature P3
apache/beam#20201 · 0 comments · 0 reactions · 0 assignees ·
-
bug core dataflow java P2 P3 runners
-
bug go harness java P3 python
apache/beam#20204 · 0 comments · 0 reactions · 0 assignees ·
-
bug core java P3
apache/beam#20205 · 2 comments · 0 reactions · 0 assignees ·
-
bug io mongodb P3 python
apache/beam#20206 · 0 comments · 0 reactions · 0 assignees ·