Issues

• [Feature Request][RunInference] Support multi-model KeyedModelHandler with ModelManager

  apache/beam#40539 · Filter by author AMOOOMA opened on Oct 12, 2026

• [Feature Request]: Optimized GCS Direct Write for Dense Keys

  awaiting triagedataflowiojavanew featureP2
  apache/beam#40533 · Filter by author tejasiyer-dev opened on Oct 12, 2026

• [Feature Request]: Support AWS secrets manager

  javanew featureP2python
  apache/beam#40528 · Filter by author shunping opened on Oct 12, 2026
  

• [Bug]: Tour of Beam Firebase Authentication fails with API key expired error

  awaiting triagebugP2website
  apache/beam#40518 · Filter by author LibenHailu opened on Oct 12, 2026

• [Task]: Clear per key watermark and timer state of the Spark 4 streaming stateful processor

  P2spark
  apache/beam#40517 · Filter by author tkaymak opened on Oct 12, 2026
  2

  

• Performance Regression or Improvement: cogbk_python_batch_load_test_2GB_of_100B_records_with_a_single_key:runtime

  awaiting triageperf-alert
  apache/beam#40512 · Filter by author github-actions opened on Oct 11, 2026
  1

• [Bug]: DataFrame API Series.value_counts(bins=...) always fails with TypeError

  P2python
  apache/beam#40503 · Filter by author anishmehta24 opened on Oct 11, 2026
  1

  

• [Feature Request]: Avoid reflective lookup and interning in BigQuery Storage Write API unknown-column collectors

  iojavanew featureP2
  apache/beam#40492 · Filter by author khaledh opened on Oct 9, 2026
  2

  

• [Feature Request]: Optionally write chunk content to the payload in QdrantWriteConfig

  P3python
  apache/beam#40476 · Filter by author pangwangshu opened on Oct 9, 2026
  4

  

• [Feature Request]: Normalize splunkIO for yaml

  new featureP2yaml
  apache/beam#40470 · Filter by author derrickaw opened on Oct 8, 2026
  1

  

• [Bug]: [RunInference] _RunInferenceDoFn acquires acquires and releases models from ModelManager under different tags when a model is updated.

  awaiting triagebugP2
  apache/beam#40469 · Filter by author tvalentyn opened on Oct 8, 2026
  5

• [Bug]: [RunInference] max_models_per_worker_hint is not enforced

  bugP2python
  apache/beam#40468 · Filter by author tvalentyn opened on Oct 8, 2026
  1

  

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

  awaiting triageP2task
  apache/beam#40454 · Filter by author ahmedabu98 opened on Oct 7, 2026

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

  P3spark
  apache/beam#40446 · Filter by author tkaymak opened on Oct 7, 2026

• [Bug]: Uncaught permission exception during VertexAIFeatureStoreEnrichmentHandler initialization

  bugP2python
  apache/beam#40442 · Filter by author vishalmore90 opened on Oct 7, 2026
  1

  

• [Bug]: BigQueryIO streaming insert silently ignores transient network errors during response body read

  awaiting triagebugdataflowjavaP2
  apache/beam#40419 · Filter by author damjad opened on Oct 5, 2026
  1

• [Feature Request]: Preserve JobMessage id on WaitForCompletion failure

  gonew featureP2
  apache/beam#40402 · Filter by author igor-dv opened on Oct 4, 2026
  1

  

• [Task]: Add a GCS temp bucket cleaner to .test-infra/tools to prevent bucket leaks

  infraP2task
  apache/beam#40347 · Filter by author shunping opened on Sep 30, 2026
  2

  

• [Bug]: DaskRunner DaskBagWindowedIterator materializes entire dataset into memory causing OOM

  bugP2python
  apache/beam#40282 · Filter by author vishalmore90 opened on Sep 25, 2026

• [Feature Request]: Add support for Python 3.15

  new featureP2python
  apache/beam#40249 · Filter by author jrmccluskey opened on Sep 23, 2026

• [Bug]: Spark Structured Streaming Runner memory leak: Datasets are persisted but never unpersisted in ParDoTranslatorBatch

  bugP2spark
  apache/beam#40243 · Filter by author vishalmore90 opened on Sep 23, 2026
  1

  

• [Bug]: SpannerIO Change Streams may skip ChildPartitionsRecord when advancing tracker to artificial query end timestamp

  iojavaP1
  apache/beam#40232 · Filter by author jiangzzhu opened on Sep 23, 2026

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

  awaiting triageinfranew featureP2
  apache/beam#40214 · Filter by author tvalentyn opened on Sep 21, 2026

• Performance Regression or Improvement: gbk_python_batch_load_test_fanout_8_times_with_2GB_10byte_records_total:runtime

  awaiting triageperf-alert
  apache/beam#40190 · Filter by author github-actions opened on Sep 20, 2026

• [Feature Request]: Honor allowMissingRequiredFields when building Storage Write API messages from TableRow

  iojavanew featureP2
  apache/beam#40189 · Filter by author khaledh opened on Sep 20, 2026
  1