Issues

• [Bug]: Stable code identifier pickling crashes cloudpickle.dumps when a sibling attribute raises on access

  awaiting triagebugP2python
  apache/beam#41002 · Filter by author praneetnadella opened on Nov 4, 2026
  1

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

  awaiting triagebugjavaP2
  apache/beam#40994 · Filter by author jonathansudhakar1 opened on Nov 4, 2026
  1

• [Failing Test]: Prism TestPersistBundle_ResidualResumeDelay/parks_with_hold_and_schedules is flaky

  awaiting triagebugfailing testflakegoP2prismtests
  apache/beam#40992 · Filter by author jonathansudhakar1 opened on Nov 4, 2026
  2

  

• [Bug]: SolaceIO persistent writes time out when concurrent bundles consume each other's ACKs

  bugiojavaP2
  apache/beam#40984 · Filter by author ngibanel opened on Nov 4, 2026
  1

• [Task]: Move BundleLifter to sdk/util and reuse it in WriteFiles

  iojavaP2task
  apache/beam#40976 · Filter by author tejasiyer-dev opened on Nov 3, 2026
  1

  

• [Task]: Spark 4 streaming runner, support Redistribute

  P3spark
  apache/beam#40950 · Filter by author tkaymak opened on Nov 2, 2026
  1

  

• [Task]: Spark 4 streaming runner, support ParDo with additional outputs

  P3spark
  apache/beam#40949 · Filter by author tkaymak opened on Nov 2, 2026
  1

  

• The PreCommit Website Stage GCS job is flaky

  bugflaky_testP1workflow_id: 64576200
  apache/beam#40934 · Filter by author github-actions opened on Nov 1, 2026

• The PreCommit Website job is flaky

  bugflaky_testP1workflow_id: 60379017
  apache/beam#40933 · Filter by author github-actions opened on Nov 1, 2026

• [Bug]: RunInference silently drops inputs when a model returns fewer predictions than inputs

  P2python
  apache/beam#40928 · Filter by author tannnmayy opened on Oct 31, 2026
  1

  

• [Feature Request]: Support PyArrow 26 in the Python SDK

  P3
  apache/beam#40919 · Filter by author alberttwong opened on Oct 30, 2026

• [Bug]: [YAML] WindowInto parses 'd' (days) as 12 hours instead of 24 hours, and ExtractWindowingInfo fails to detect duplicate schema fields

  P2pythonyaml
  apache/beam#40902 · Filter by author LibenHailu opened on Oct 30, 2026
  1

  

• [Feature Request] : Add an experimental beam command to the Python SDK

  awaiting triagenew featureP2pythonyaml
  apache/beam#40891 · Filter by author jk-shah opened on Oct 29, 2026
  1

• [Bug]: Delta Lake CDC should compare start and end schema during read and reject pipelines when schema doesn't match

  bugP2
  apache/beam#40853 · Filter by author chamikaramj opened on Oct 27, 2026 · 2.79.0 Release
  5

  

• [Feature Request]: Vespa ingestion (VespaWriteConfig) for Python ml.rag

  awaiting triagenew featureP2python
  apache/beam#40837 · Filter by author pangwangshu opened on Oct 27, 2026
  5

• [Task]: Publicize new Iceberg CDC features

  iojavaP2task
  apache/beam#40830 · Filter by author ahmedabu98 opened on Oct 26, 2026
  

• [Task]: Achieve v3 compliance for IcebergIO

  P2task
  apache/beam#40829 · Filter by author ahmedabu98 opened on Oct 26, 2026
  

• [Task]: Support CDC use cases in Beam SQL

  P2task
  apache/beam#40828 · Filter by author ahmedabu98 opened on Oct 26, 2026
  

• [Bug]: DeferredSeries.duplicated() raises WontImplementError due to incorrect column indexing

  bugP2python
  apache/beam#40814 · Filter by author dhanusharer opened on Oct 26, 2026
  1

  

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

  apache/beam#40809 · Filter by author github-actions opened on Oct 26, 2026

• [Failing Test]: BigqueryClient.queryUnflattened fails BigQuery ITs on a transient 503

  apache/beam#40792 · Filter by author mxtymoshyk opened on Oct 25, 2026

• [Task]: Spark 4 streaming sibling scans of one unbounded source can disagree on a deadline cut batch

  apache/beam#40786 · Filter by author tkaymak opened on Oct 25, 2026
  1

  

• [Feature Request]: Enable Transaction Metadata Events in DebeziumIO JSON Output

  awaiting triageiojavanew featureP2
  apache/beam#40784 · Filter by author ilyasahsan123 opened on Oct 25, 2026

• The PostCommit Java ValidatesRunner Dataflow Streaming TagEncodingV2 job is flaky

  bugflaky_testP1workflow_id: 235658982
  apache/beam#40764 · Filter by author github-actions opened on Oct 24, 2026

• [Task]: Un-skip Iceberg CDC tests when Managed service gets updated to 2.77

  iojavaP2task
  apache/beam#40732 · Filter by author ahmedabu98 opened on Oct 22, 2026