apache/beam

View on GitHub

Apache 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 10h
Merged PRs (30d): 197

Dominant language: Java
License: Apache-2.0
Last GitHub push: Sep 18, 2026
Latest indexed: Sep 14, 2026
Contributing guide: Contributing guide
Code of conduct: Code of conduct
Beginner labels: good first issue

Beginner friendly Everything

Open All

3,806 open issues indexed

Beam Dependency Update requests autobugs are sometimes unactionable Open

bug dependencies P3

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/beam#21309 · Opened Jun 4, 2022
Support for locked buckets in Beam Open

gcp improvement io java P3

Difficulty 4/5 3-5 days Newbie friendliness 30/100

apache/beam#21308 · Opened Jun 4, 2022
OnWindowExpiration is not supported for portable runners Open

beam-model new feature P3

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21307 · Opened Jun 4, 2022
Flink runner failing testOnWindowTimestampSkew Open

bug disabled test failing test flink P3 runners

Difficulty 4/5 3-5 days Newbie friendliness 38/100

apache/beam#21306 · Opened Jun 4, 2022
Flink runner does not support PerKeyOrdering Open

flink new feature P3 runners

Difficulty 2/5 1-3 hours Newbie friendliness 35/100

apache/beam#21305 · Opened Jun 4, 2022
[Playground] Clean bucket during CD step Open

beam-playground new feature P3

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21303 · Opened Jun 4, 2022
There should be single source of truth for the project version Open

build P3 wish

apache/beam#21302 · 7 comments · 1 assignee · Opened Jun 4, 2022
Add BigQuery pushdown stats to grafana. Open

dsl new feature P3 sql

Difficulty 3/5 1-2 days Newbie friendliness 35/100

apache/beam#21301 · Opened Jun 4, 2022
Beam examples failing for some runners: game_stats and leader_board Open

examples new feature P3 python tests

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21300 · Opened Jun 4, 2022
hcatalog is broken in java 11 Open

bug dsl hcatalog io java P3 sql

Difficulty 4/5 3-5 days Newbie friendliness 20/100

apache/beam#21299 · Opened Jun 4, 2022
[Playground] Fix search in Code editor Open

beam-playground bug P3

Difficulty 3/5 1-2 days Newbie friendliness 30/100

apache/beam#21297 · Opened Jun 4, 2022
Serialize/deserialize StsClient when serializing/deserializing StsAssumeRoleCredentialsProvider Open

aws improvement io java P3

Difficulty 3/5 1-2 days Newbie friendliness 45/100

apache/beam#21296 · 1 reaction · Opened Jun 4, 2022
[Playground] Add trigger to restart CI Open

beam-playground P3 task

Difficulty 3/5 1-2 days Newbie friendliness 25/100

apache/beam#21295 · Opened Jun 4, 2022
IsmSideInputReaderTest.verifyMap does not make some contains assertions Open

bug dataflow P3 runners

Difficulty 3/5 1-2 days Newbie friendliness 48/100

apache/beam#21294 · Opened Jun 4, 2022
Fixing typos Open

examples improvement P3 python

Difficulty 2/5 1-3 hours Newbie friendliness 35/100

apache/beam#21292 · Opened Jun 4, 2022
[Playground] Increase test coverage for the preparers package Open

beam-playground P3 sub-task

Difficulty 3/5 1-2 days Newbie friendliness 25/100

apache/beam#21290 · Opened Jun 4, 2022
[Playground] Increase test coverage for the cloud_bucket package Open

beam-playground P3 sub-task

Difficulty 3/5 1-2 days Newbie friendliness 25/100

apache/beam#21289 · Opened Jun 4, 2022
[Playground] Increase test coverage Open

beam-playground improvement P3

Difficulty 5/5 Over a week Newbie friendliness 20/100

apache/beam#21288 · 1 comment · Opened Jun 4, 2022
Support for non-private key auth authentication in SnowflakeIO for streaming write Open

io java new feature P3 snowflake

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/beam#21287 · Opened Jun 4, 2022
Add support for CloudEvent 1.0 specification Open

beam-model extensions gcp ideas new feature P3

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/beam#21286 · Opened Jun 4, 2022
[Playground] Support unit tests for SCIO Open

beam-playground new feature P3

Difficulty 5/5 Over a week Newbie friendliness 20/100

apache/beam#21285 · Opened Jun 4, 2022
FieldAccessDescriptorParser failures throw NPE Open

bug core java P3

Difficulty 3/5 1-2 days Newbie friendliness 45/100

apache/beam#21284 · Opened Jun 4, 2022
Test non default pickle library Open

core improvement P3 python

Difficulty 4/5 3-5 days Newbie friendliness 45/100

apache/beam#21282 · Opened Jun 4, 2022
syl test Open

beam-model improvement P3

Difficulty 5/5 Over a week Newbie friendliness 1/100

apache/beam#21280 · Opened Jun 4, 2022
[Playground] Make categories as filters in the examples catalog Open

beam-playground new feature P3

Difficulty 5/5 Over a week Newbie friendliness 20/100

apache/beam#21278 · Opened Jun 4, 2022
Use ProjectionConsumer in FieldAccessVisitor. Open

core improvement java P3

Difficulty 3/5 1-2 days Newbie friendliness 45/100

apache/beam#21276 · Opened Jun 4, 2022
[Playground] Add an ability to periodically update precompiled examples in the cache Open

beam-playground improvement P4

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21273 · Opened Jun 4, 2022
[Playground] Multifile examples execution support Open

beam-playground new feature P4

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21272 · Opened Jun 4, 2022
Delete orphaned files Open

bug files io P2 python

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21269 · Opened Jun 4, 2022
Python AfterAny, AfterAll do not follow spec Open

bug core P2 python

Difficulty 4/5 3-5 days Newbie friendliness 42/100

apache/beam#21262 · 5 comments · Opened Jun 4, 2022
Python DirectRunner does not emit data at GC time Open

bug core direct P2 python runners

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21260 · 1 comment · Opened Jun 4, 2022
Dataflow error in CombinePerKey operation Open

bug core P2 python

Difficulty 4/5 3-5 days Newbie friendliness 30/100

apache/beam#21258 · Opened Jun 4, 2022
A load test for DebeziumIO that uses postgres as a database Open

bug cross-language debezium io java P2

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21256 · 1 comment · Opened Jun 4, 2022
GCSFileSystem is not facilitating injection of the gcs url Open

gcp improvement io P2 python

Difficulty 3/5 1-2 days Newbie friendliness 48/100

apache/beam#21255 · Opened Jun 4, 2022
Optimize Java SDK harness Open

harness improvement java P2

apache/beam#21250 · 1 comment · 1 assignee · Opened Jun 4, 2022
Pub/Sub Lite support for Python SDK Open

gcp io new feature P2 python

Difficulty 5/5 Over a week Newbie friendliness 25/100

apache/beam#21248 · Opened Jun 4, 2022
"Dead letter" handling for problem rows in BigQueryIO Storage Write API Open

gcp io java new feature P2

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21247 · 1 comment · Opened Jun 4, 2022
Support a non-exactly once StorageAPI BigQuery sink. Open

gcp io java new feature P2

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21243 · Opened Jun 4, 2022
XmlIO should support XML namespaces Open

improvement io java P2 xml

Difficulty 4/5 3-5 days Newbie friendliness 25/100

apache/beam#21241 · Opened Jun 4, 2022
Java PostCommits produce too many spanner databases Open

bug P2 tests

Difficulty 3/5 1-2 days Newbie friendliness 45/100

apache/beam#21240 · Opened Jun 4, 2022
DataFrame API errors should identify culprit operation in user code Open

dataframe improvement P2

Difficulty 5/5 Over a week Newbie friendliness 30/100

apache/beam#21239 · Opened Jun 4, 2022
Python SDK harness should use runner capability to decide whether to send monitoring infos with short id. Open

harness improvement P2 python

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21238 · Opened Jun 4, 2022
Release validation script should not use gnome-terminal Open

improvement P2 release

Difficulty 2/5 1-3 hours Newbie friendliness 42/100

apache/beam#21237 · Opened Jun 4, 2022
Fix pylint warning: Using open without explicitly specifying an encoding (unspecified-encoding) Open

core P2 python task tests

Difficulty 4/5 3-5 days Newbie friendliness 25/100

apache/beam#21236 · Opened Jun 4, 2022
Java BigqueryIO source should have a "read all" feature Open

gcp io java new feature P2

Difficulty 5/5 Over a week Newbie friendliness 35/100

apache/beam#21235 · Opened Jun 4, 2022
Implement Flink "uber jar" job server in Go SDK. Open

flink go new feature P2 runners

Difficulty 4/5 3-5 days Newbie friendliness 38/100

apache/beam#21234 · 1 comment · Opened Jun 4, 2022
Portable representation of "packed bitset indicating null fields" in beam Row format is not compatible with jvm representations Open

bug cross-language P3

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21232 · Opened Jun 4, 2022
Enable JavaUsingPython CrossLanguageValidateRunner test for dataflow runner v2 Open

cross-language improvement P3 tests

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21231 · Opened Jun 4, 2022
error-prone UnusedVariable check raises false positives for StateId and TimerId usages Open

core java P3 task

Difficulty 3/5 1-2 days Newbie friendliness 35/100

apache/beam#21230 · Opened Jun 4, 2022
Error running Top transform in Dataflow Open

bug core dataflow P3 python runners

Difficulty 4/5 3-5 days Newbie friendliness 35/100

apache/beam#21229 · 2 comments · Opened Jun 4, 2022

apache/beam

Get new issues in your inbox