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,805 open issues indexed

[Spark] Structured streaming runner: asynchronous cancel() should not report CANCELLED before the execution ended Open

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

apache/beam#40120 · 1 comment · Opened Sep 14, 2026
[Bug]: BigQueryIO Storage Write API failed-rows output crashes: TIMESTAMP printed with both a space and a T separator, then parsed by Instant.parse Open

awaiting triage bug dataflow io java P2 python

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

apache/beam#40110 · 1 comment · Opened Sep 13, 2026
[Feature Request]: Implement JsonIO.read() / readRows() for the Java SDK Open

io java new feature P2

apache/beam#40086 · 1 comment · 1 assignee · Opened Sep 9, 2026
[Bug]: Inconsistent types for tuple fields in Beam Schema and Row through serialization boundary Open

bug P2 python schemas

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

apache/beam#40079 · 1 comment · Opened Sep 9, 2026
[Feature Request]: Improve exception visibility in `FileSystems.matchSingleFileSpec` to prevent masking of root-cause Exceptions Open

io java new feature P2

apache/beam#40076 · 2 comments · 1 assignee · Opened Sep 9, 2026
Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec Open

awaiting triage perf-alert

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

apache/beam#40067 · 1 comment · Opened Sep 8, 2026
[Feature Request]: Add read() support to Java ClickHouseIO (currently write-only) Open

io java new feature P2

apache/beam#40048 · 1 comment · 1 assignee · Opened Sep 7, 2026
[Feature Request]: Add Chroma vector database ingestion connector for RAG pipelines Open

io new feature P2 python

apache/beam#40047 · 1 comment · 1 assignee · Opened Sep 7, 2026
[Bug]: pubsubio imports google.golang.org/genproto/googleapis/pubsub/v1, which was removed from current genproto releasess Open

bug go io P2

apache/beam#40018 · 1 comment · 1 assignee · Opened Sep 4, 2026
Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime Open

awaiting triage perf-alert

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

apache/beam#40005 · 1 comment · Opened Sep 3, 2026
[Bug]: Flink drops watermark holds for records awaiting a checkpoint Open

flink P1

apache/beam#39991 · 1 comment · 1 assignee · Opened Sep 3, 2026
[Feature Request]: Create a merge-on-read Iceberg sink Open

io java new feature P2

apache/beam#39979 · 1 comment · 1 assignee · Opened Sep 2, 2026
[Bug]: BigtableIO.readChangeStream() with RESUME_OR_NEW can start duplicate consumers inside one Dataflow job Open

awaiting triage bug io P2

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

apache/beam#39970 · Opened Sep 2, 2026
[Feature Request]: Create Apache Beam PostgreSQL I/O Connector with streaming support Open

io new feature P2

apache/beam#39959 · 1 comment · 1 assignee · Opened Sep 1, 2026
[Bug]: PickleCoder/_MemoizingPickleCoder.as_deterministic_coder() raises TypeError Open

P2

apache/beam#39942 · 1 comment · 1 assignee · Opened Aug 31, 2026
[IAC_DRIFT_SA_KEY] Action Required: Unmanaged Service Account Keys Detected Open

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

apache/beam#39932 · Opened Aug 31, 2026
[ACCOUNT_KEYS_POLICY] Action Required: Service Account Policy Drift Open

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

apache/beam#39931 · Opened Aug 31, 2026
[Feature Request]: Wait.on for Go SDK Open

go new feature P2

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

apache/beam#39909 · 5 comments · Opened Aug 27, 2026
[Bug]: Left frame no longer showing in Javadoc Open

bug java P3 website

apache/beam#39895 · 3 comments · 1 assignee · Opened Aug 26, 2026
[IAC_DRIFT_IAM_USER] Action Required: Unauthorized IAM Users Detected Open

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

apache/beam#39870 · Opened Aug 24, 2026
IAM Policy Non-Compliance Detected Open

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

apache/beam#39869 · Opened Aug 24, 2026
[Bug]:KafkaIO OAUTHBEARER auth against GCP Managed Service for Apache Kafka broken starting 2.69.0 (works on 2.68.0) Open

awaiting triage bug dataflow P2

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

apache/beam#39789 · 2 comments · Opened Aug 17, 2026
[Bug]: Java FlinkRunner OrderedListState silently overwrites duplicate elements sharing same timestamps Open

bug flink P1

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

apache/beam#39782 · 2 comments · Opened Aug 17, 2026
[Feature Request]: Bound PGBKCVOperation precombine table by in-memory size, not key count Open

P3

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

apache/beam#39754 · Opened Aug 14, 2026
[Bug]: SQL AVG rounds to 10 significant digits, flipping the sign on large BIGINT values Open

java P2

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

apache/beam#39751 · Opened Aug 14, 2026
[Bug]: Row.toString throws for an ITERABLE field that is not backed by a List Open

java P3

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

apache/beam#39749 · Opened Aug 14, 2026
[Feature Request]: Implement Side-Input Table Cache for IcebergIO Open

IcebergIO io java new feature P2

apache/beam#39723 · 1 assignee · Opened Aug 11, 2026
[Task][prism]: Separate management logs from pipeline logs, with rolling log files Open

go P2 prism task

apache/beam#39709 · 1 comment · 1 assignee · Opened Aug 11, 2026
[Task]: Go SDK portable logical type support Open

go good first issue P2 task

apache/beam#39684 · 3 comments · 2 assignees · Opened Aug 7, 2026
Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec Open

awaiting triage perf-alert

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

apache/beam#39667 · 2 comments · Opened Aug 7, 2026
Kafka Streams runner: committed metrics Open

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

apache/beam#39635 · Opened Aug 5, 2026
Kafka Streams runner: finalize unbounded source checkpoints Open

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

apache/beam#39634 · Opened Aug 5, 2026
Kafka Streams runner: bundles are not bounded by time Open

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

apache/beam#39633 · 1 comment · Opened Aug 5, 2026
Kafka Streams runner: TestStream Open

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

apache/beam#39632 · Opened Aug 5, 2026
Kafka Streams runner: splittable DoFn Open

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

apache/beam#39631 · Opened Aug 5, 2026
Kafka Streams runner: merging windows and custom WindowFns Open

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

apache/beam#39630 · Opened Aug 5, 2026
Kafka Streams runner: stateful ParDo and user timers Open

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

apache/beam#39629 · Opened Aug 5, 2026
Kafka Streams runner: side inputs Open

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

apache/beam#39628 · Opened Aug 5, 2026
Kafka Streams runner: read a source's splits in parallel Open

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

apache/beam#39626 · Opened Aug 5, 2026
Upgrade vendored grpc to remove vulnerabilities coming from netty Open

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

apache/beam#39624 · 2 reactions · Opened Aug 5, 2026
[Task]: Investigate native ARM runners for Python aarch64 wheels Open

awaiting triage infra P2 python task

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

apache/beam#39620 · Opened Aug 5, 2026
[Bug]: SolaceIO write transform loses output elements in batch pipelines Open

bug dataflow io P2

apache/beam#39589 · 2 comments · 2 assignees · Opened Aug 3, 2026
[Bug]: SolaceIO write transform does not output all publish results Open

awaiting triage bug dataflow io P2

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

apache/beam#39588 · Opened Aug 3, 2026
[Task]: Set the Beam user agent on the Python boto3 S3 client Open

P3

apache/beam#39573 · 1 comment · 1 assignee · Opened Jul 31, 2026
Upgrade DebeziumIO to Debezium 3.5.2.Final Open

io java P2

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

apache/beam#39568 · Opened Jul 31, 2026
Kafka Streams runner: lifecycle management for runner-created topics Open

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

apache/beam#39566 · Opened Jul 31, 2026
Kafka Streams runner: expose topic-level configuration for runner-created topics Open

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

apache/beam#39565 · Opened Jul 31, 2026
[Bug]: Performance regression and stuck jobs due to gcs-connector v3 upgrade Open

awaiting triage bug java P2

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

apache/beam#39548 · Opened Jul 29, 2026
[GSoC 2026] Kafka Streams runner: un-sickbay ParDoTest$LifecycleTests.testParDoWithErrorInStartBatch Open

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

apache/beam#39452 · Opened Jul 23, 2026
[Feature Request]: OpenLineage extension for the Java SDK Open

java P2

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

apache/beam#39427 · Opened Jul 22, 2026

apache/beam

Get new issues in your inbox