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 2h
- Merged PRs (30d)
- 205
- 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
-
Main thread needs to re-throw worker exceptions for ValidatesRunner tests that expects exceptions. Openmapreduce new feature P3 runners
apache/beam#18422 · 0 comments · 0 reactions · 0 assignees ·
-
gcp io java new feature P3
-
bug P3 runners spark
apache/beam#18424 · 0 comments · 0 reactions · 0 assignees ·
-
P3 runners spark task
apache/beam#18425 · 0 comments · 0 reactions · 0 assignees ·
-
bug P3 runners spark
apache/beam#18426 · 0 comments · 0 reactions · 0 assignees ·
-
bug core direct P3 runners
apache/beam#18427 · 0 comments · 0 reactions · 0 assignees ·
-
core good first issue improvement P3 runners
apache/beam#18428 · 0 comments · 0 reactions · 0 assignees ·
-
gcp io java new feature P3 pubsub
apache/beam#18429 · 0 comments · 0 reactions · 0 assignees ·
-
apex bug core flink P3 runners spark
apache/beam#18430 · 0 comments · 0 reactions · 0 assignees ·
-
gcp improvement io java P3
apache/beam#18431 · 0 comments · 0 reactions · 0 assignees ·
-
beam-model bug P3 portability
apache/beam#18435 · 0 comments · 0 reactions · 0 assignees ·
-
bug ideas io P3
apache/beam#18436 · 0 comments · 0 reactions · 0 assignees ·
-
bug P3 tests
apache/beam#18437 · 0 comments · 0 reactions · 0 assignees ·
-
Batching DoFn Opencore new feature P3 python
apache/beam#18438 · 0 comments · 0 reactions · 0 assignees ·
-
core improvement P3 python
apache/beam#18439 · 0 comments · 0 reactions · 0 assignees ·
-
bug P3 tests
apache/beam#18440 · 0 comments · 0 reactions · 0 assignees ·
-
bug core P3 python
apache/beam#18441 · 0 comments · 0 reactions · 0 assignees ·
-
bug core P3 python
apache/beam#18442 · 0 comments · 0 reactions · 0 assignees ·
-
flink improvement P3 runners
apache/beam#18443 · 0 comments · 0 reactions · 0 assignees ·
-
core improvement P3 python
apache/beam#18444 · 0 comments · 0 reactions · 0 assignees ·
-
bug dataflow direct gcp io java P3 runners
-
bug dataflow P3 runners
apache/beam#18446 · 0 comments · 0 reactions · 0 assignees ·
-
mapreduce P3 runners task
apache/beam#18447 · 0 comments · 0 reactions · 0 assignees ·
-
mapreduce P3 runners task
apache/beam#18448 · 0 comments · 0 reactions · 0 assignees ·
-
bug build P3
apache/beam#18449 · 0 comments · 0 reactions · 0 assignees ·
-
mapreduce new feature P3 runners
apache/beam#18450 · 0 comments · 0 reactions · 0 assignees ·
-
bug ideas io P3
apache/beam#18451 · 0 comments · 0 reactions · 0 assignees ·
-
jstorm P3 runners task
apache/beam#18452 · 0 comments · 0 reactions · 0 assignees ·
-
jstorm P3 runners task
apache/beam#18453 · 0 comments · 0 reactions · 0 assignees ·
-
jstorm P3 runners task
apache/beam#18454 · 0 comments · 0 reactions · 0 assignees ·
-
jstorm P3 runners task
apache/beam#18455 · 0 comments · 0 reactions · 0 assignees ·
-
beam-model P3 tests
apache/beam#18456 · 0 comments · 0 reactions · 0 assignees ·
-
bug dataflow P3 runners
apache/beam#18457 · 0 comments · 0 reactions · 0 assignees ·
-
bug core good first issue java P3
apache/beam#18458 · 0 comments · 0 reactions · 0 assignees ·
-
bug core java P3
apache/beam#18459 · 2 comments · 0 reactions · 0 assignees ·
-
bug core java P3 python
apache/beam#18460 · 0 comments · 0 reactions · 0 assignees ·
-
bug core java P3
apache/beam#18461 · 0 comments · 0 reactions · 0 assignees ·
-
bug core java P3
apache/beam#18462 · 0 comments · 0 reactions · 0 assignees ·
-
FileBasedSink writing to incorrect path when path prefixe has no file component in path (e.g. /tmp/) Openbug core java P3
apache/beam#18463 · 0 comments · 0 reactions · 0 assignees ·
-
core java new feature P3 python
-
beam-model bug core java P3 python
apache/beam#18465 · 0 comments · 0 reactions · 0 assignees ·
-
core improvement java P3
apache/beam#18466 · 0 comments · 0 reactions · 0 assignees ·
-
bug core java P3
apache/beam#18467 · 0 comments · 0 reactions · 0 assignees ·
-
core improvement java P3
apache/beam#18468 · 0 comments · 0 reactions · 0 assignees ·
-
core improvement java P3
apache/beam#18469 · 0 comments · 0 reactions · 0 assignees ·
-
core flink improvement java P3 runners spark
-
flink P3 runners spark sub-task
apache/beam#18471 · 0 comments · 0 reactions · 0 assignees ·
-
core java P3 runners sub-task
apache/beam#18472 · 0 comments · 0 reactions · 0 assignees ·
-
bug core java P3
apache/beam#18473 · 0 comments · 0 reactions · 0 assignees ·
-
bug core java P3
apache/beam#18474 · 0 comments · 0 reactions · 0 assignees ·