apache/beam

Issues somebody may already be working on are listed last. List everything by date

• [Feature Request]: [Python] Add Variance, StandardDeviation, Covariance, and LinearRegression to apache_beam.transforms.combiners

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  P2 python

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

  apache/beam#41171 · Opened Nov 10, 2026

  Maintainers usually reply within 1 day

• [Bug]: Dataflow streaming on SDK 2.74+ (Windmill DirectPath on by default) causes frequent UnboundedSource reader invalidations, re-processing and CPU saturation

  May be free again A pull request for this issue was closed without being merged. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage bug dataflow io java P2

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

  apache/beam#41108 · 5 comments · Opened Nov 9, 2026

  Maintainers usually reply within 1 day

• [Bug]: [Python] WriteToParquet fails on schema'd PCollections whose nested struct fields hold beam.Row values

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  io P2 python yaml

  Difficulty 3/5 Half a day Newbie friendliness 70/100

  apache/beam#41101 · Opened Nov 9, 2026

  Maintainers usually reply within 1 day

• [Bug]: [Python] Type inference returns Any for attributes of NamedTuple-typed and nullable nested rows

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage bug P2 python yaml

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

  apache/beam#41099 · Opened Nov 9, 2026

  Maintainers usually reply within 1 day

• [Bug]: [Python] ReadFromJson stores nested JSON objects and arrays as Python repr strings

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage bug io P2 yaml

  Difficulty 3/5 Half a day Newbie friendliness 70/100

  apache/beam#41098 · Opened Nov 9, 2026

  Maintainers usually reply within 1 day

• Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage perf-alert

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

  apache/beam#41089 · Opened Nov 8, 2026

  Maintainers usually reply within 1 day

• [Bug]: [Spark/Python] --spark_submit_uber_jar fails in StorageLevelFactory.create due to Python runner name lookup

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage bug P2 python spark

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

  apache/beam#41080 · Opened Nov 8, 2026

  Maintainers usually reply within 1 day

• [Bug]: [Python] DirectRunner Prism fallback to BundleBasedDirectRunner fails with NotImplementedError on batched DoFns (WriteToParquet)

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage bug P2 python

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

  apache/beam#41078 · Opened Nov 8, 2026

  Maintainers usually reply within 1 day

• [Bug]: Beam SQL Parquet tables fail on TIME columns: Unhandled logical type beam:logical_type:time:v1

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage bug java P2

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

  apache/beam#40994 · 1 comment · Opened Nov 4, 2026

  Maintainers usually reply within 1 day

• [IAC_DRIFT_SA_KEY] Action Required: Unmanaged Service Account Keys Detected

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#40809 · Opened Oct 26, 2026

  Maintainers usually reply within 1 day

• The PostCommit Java ValidatesRunner Dataflow Streaming TagEncodingV2 job is flaky

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  bug flaky_test P1 workflow_id: 235658982

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

  apache/beam#40764 · Opened Oct 24, 2026

  Maintainers usually reply within 1 day

• The PostCommit Java ValidatesRunner Dataflow V2 Streaming job is flaky

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  bug flaky_test P1 workflow_id: 69423704

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

  apache/beam#40727 · Opened Oct 22, 2026

  Maintainers usually reply within 1 day

• [Feature Request]: Allow non-identifier column names in Python Row

  May be free again @schizophrenicmaniac claimed this 22 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  new feature P2

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

  apache/beam#40698 · 3 comments · Opened Oct 20, 2026

  Maintainers usually reply within 1 day

• Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_100KB_records:runtime

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage perf-alert

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

  apache/beam#40643 · 1 comment · Opened Oct 16, 2026

  Maintainers usually reply within 1 day

• Performance Regression or Improvement: combine_python_batch_2gb_10_byte_records:runtime

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage perf-alert

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

  apache/beam#40642 · Opened Oct 16, 2026

  Maintainers usually reply within 1 day

• [Feature Request]: Support non-default Google Cloud universe domains (GOOGLE_CLOUD_UNIVERSE_DOMAIN)

  May be free again @shunping claimed this 29 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  go java new feature P2 python

  apache/beam#40569 · 1 assignee · Opened Oct 14, 2026

  Maintainers usually reply within 1 day

• [Feature Request]: Upgrade Gradle wrapper to 9.x for JDK 25 support

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage java new feature P2

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

  apache/beam#40556 · 3 comments · Opened Oct 13, 2026

  Maintainers usually reply within 1 day

• [Feature Request]: Honor --quota_project_id in Python GCS/Pub/Sub IO and the Java-backed BigQuery STORAGE_WRITE_API path

  May be free again @shahar1 claimed this 29 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  dataflow io new feature P2 python

  apache/beam#40555 · 2 comments · 1 assignee · Opened Oct 13, 2026

  Maintainers usually reply within 1 day

• [Task]: Use Timestamp logical type in Beam SQL

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage P2 task

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

  apache/beam#40454 · 1 comment · Opened Oct 7, 2026

  Maintainers usually reply within 1 day

• [Task]: Tighten the late data bound of the Spark 4 streaming stateful ParDo to the previous batch watermark

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  P3 spark

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

  apache/beam#40446 · Opened Oct 7, 2026

  Maintainers usually reply within 1 day

• [Feature Request]: Add support for Python 3.15

  May be free again @jrmccluskey claimed this 29 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  new feature P2 python

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

  apache/beam#40249 · 1 comment · 1 assignee · Opened Sep 23, 2026

  Maintainers usually reply within 1 day

• [Feature Request]: Implement least-privilege access for GKE workload hosting Beam metrics.

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage infra new feature P2

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

  apache/beam#40214 · 2 comments · Opened Sep 21, 2026

  Maintainers usually reply within 1 day

• Performance Regression or Improvement: gbk_python_batch_load_test_fanout_8_times_with_2GB_10byte_records_total:runtime

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage perf-alert

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

  apache/beam#40190 · Opened Sep 20, 2026

  Maintainers usually reply within 1 day

• [Feature Request]: Allow ADK Model Handler to use local models

  May be free again @damccorm claimed this 54 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  new feature P2 python

  apache/beam#40179 · 1 assignee · Opened Sep 18, 2026

  Maintainers usually reply within 1 day

• [Bug]: Go SDK row coder encodes negative INT32 schema fields as 10 byte varints that Java and Python reject

  May be free again @Eliaaazzz claimed this 55 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  go P2

  apache/beam#40159 · 2 comments · 1 assignee · Opened Sep 17, 2026

  Maintainers usually reply within 1 day

• [Feature Request]: Implement JsonIO.read() / readRows() for the Java SDK

  May be free again @nitinware claimed this 63 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  io java new feature P2

  apache/beam#40086 · 1 comment · 1 assignee · Opened Sep 9, 2026

  Maintainers usually reply within 1 day

• Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage perf-alert

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

  apache/beam#40067 · 1 comment · Opened Sep 8, 2026

  Maintainers usually reply within 1 day

• [Feature Request]: Add read() support to Java ClickHouseIO (currently write-only)

  May be free again @nitinware claimed this 65 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  io java new feature P2

  apache/beam#40048 · 1 comment · 1 assignee · Opened Sep 7, 2026

  Maintainers usually reply within 1 day

• [Feature Request]: Add Chroma vector database ingestion connector for RAG pipelines

  May be free again @nitinware claimed this 65 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  io new feature P2 python

  apache/beam#40047 · 1 comment · 1 assignee · Opened Sep 7, 2026

  Maintainers usually reply within 1 day

• Performance Regression or Improvement: sideinpts_python_batch_1gb_1kb_10workers_1000window_99key_percent_dict:runtime

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage perf-alert

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

  apache/beam#40005 · 3 comments · Opened Sep 3, 2026

  Maintainers usually reply within 1 day

• [ACCOUNT_KEYS_POLICY] Action Required: Service Account Policy Drift

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39931 · Opened Aug 31, 2026

  Maintainers usually reply within 1 day

• [Bug]: Left frame no longer showing in Javadoc

  May be free again @nitinware claimed this 65 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  bug java P3 website

  apache/beam#39895 · 3 comments · 1 assignee · Opened Aug 26, 2026

  Maintainers usually reply within 1 day

• [IAC_DRIFT_IAM_USER] Action Required: Unauthorized IAM Users Detected

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39870 · Opened Aug 24, 2026

  Maintainers usually reply within 1 day

• IAM Policy Non-Compliance Detected

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39869 · Opened Aug 24, 2026

  Maintainers usually reply within 1 day

• [Feature Request]: Bound PGBKCVOperation precombine table by in-memory size, not key count

  May be free again A pull request for this issue was closed without being merged. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  P3

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

  apache/beam#39754 · Opened Aug 14, 2026

  Maintainers usually reply within 1 day

• [Task][prism]: Separate management logs from pipeline logs, with rolling log files

  May be free again @moawnallah claimed this 93 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  go P2 prism task

  apache/beam#39709 · 1 comment · 1 assignee · Opened Aug 11, 2026

  Maintainers usually reply within 1 day

• [Task]: Go SDK portable logical type support

  May be free again @Eliaaazzz claimed this 55 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  go good first issue P2 task

  apache/beam#39684 · 5 comments · 3 assignees · Opened Aug 7, 2026

  Maintainers usually reply within 1 day

• Kafka Streams runner: committed metrics

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39635 · Opened Aug 5, 2026

  Maintainers usually reply within 1 day

• Kafka Streams runner: finalize unbounded source checkpoints

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39634 · Opened Aug 5, 2026

  Maintainers usually reply within 1 day

• Kafka Streams runner: bundles are not bounded by time

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39633 · 1 comment · Opened Aug 5, 2026

  Maintainers usually reply within 1 day

• Kafka Streams runner: TestStream

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39632 · Opened Aug 5, 2026

  Maintainers usually reply within 1 day

• Kafka Streams runner: splittable DoFn

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39631 · Opened Aug 5, 2026

  Maintainers usually reply within 1 day

• Kafka Streams runner: merging windows and custom WindowFns

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39630 · Opened Aug 5, 2026

  Maintainers usually reply within 1 day

• Kafka Streams runner: stateful ParDo and user timers

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39629 · Opened Aug 5, 2026

  Maintainers usually reply within 1 day

• Kafka Streams runner: side inputs

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39628 · Opened Aug 5, 2026

  Maintainers usually reply within 1 day

• Kafka Streams runner: read a source's splits in parallel

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39626 · Opened Aug 5, 2026

  Maintainers usually reply within 1 day

• Upgrade vendored grpc to remove vulnerabilities coming from netty

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39624 · 2 reactions · Opened Aug 5, 2026

  Maintainers usually reply within 1 day

• [Task]: Investigate native ARM runners for Python aarch64 wheels

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  awaiting triage infra P2 python task

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

  apache/beam#39620 · Opened Aug 5, 2026

  Maintainers usually reply within 1 day

• [Task]: Set the Beam user agent on the Python boto3 S3 client

  May be free again @goanpeca claimed this 103 days ago, and no pull request is open. Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel
  P3

  apache/beam#39573 · 1 comment · 1 assignee · Opened Jul 31, 2026

  Maintainers usually reply within 1 day

• Kafka Streams runner: lifecycle management for runner-created topics

  Open

  ⋯Report a problem with this issue

  • Is something wrong?

  • Already taken
  • Not beginner-friendly
  • Stale or invalid
  • Something else…
  • Send Cancel

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

  apache/beam#39566 · Opened Jul 31, 2026

  Maintainers usually reply within 1 day