Issues

• [Feature Request]: Enable Schema Change Events in DebeziumIO JSON Output

  awaiting triageiojavanew featureP2
  apache/beam#41330 · Filter by author ilyasahsan123 opened on Nov 14, 2026

• [Bug]: DataFrame API groupby on a categorical column returns duplicate groups with null values

  P2python
  apache/beam#41321 · Filter by author anishmehta24 opened on Nov 13, 2026

• [Feature Request]: Show a live view of streaming records when running an unbounded Beam SQL query

  new featureP2
  apache/beam#41313 · Filter by author ahmedabu98 opened on Nov 13, 2026
  

• [Feature Request]: [YAML] Declarative multi-table streaming materialized flows with FRESHNESS targets

  apache/beam#41312 · Filter by author jk-shah opened on Nov 13, 2026

• [Feature Request]: [Streaming/YAML] Add external index-backed DeltaJoin transform for bounded-state dual-stream joins

  apache/beam#41311 · Filter by author jk-shah opened on Nov 13, 2026

• [Feature Request]: [State] Add declarative per-key StateSpec TTL and state schema evolution

  apache/beam#41310 · Filter by author jk-shah opened on Nov 13, 2026

• [Feature Request]: [SQL/YAML] Support ASOF JOIN for point-in-time streaming enrichment

  apache/beam#41309 · Filter by author jk-shah opened on Nov 13, 2026

• [Feature Request]: [SQL/YAML] Add ML_PREDICT and VECTOR_SEARCH SQL TVFs backed by RunInference

  apache/beam#41308 · Filter by author jk-shah opened on Nov 13, 2026

• [Bug]: Python Reify.Window, Reify.WindowInValue and Reify.TimestampInValue fail on inputs with a type hint

  P2python
  apache/beam#41306 · Filter by author sohailshk opened on Nov 13, 2026
  1

  

• [Bug]: DataFrame API groupby().skew() on integer columns has a float result but an integer proxy (to_pcollection fails)

  P2python
  apache/beam#41305 · Filter by author sohailshk opened on Nov 13, 2026
  1

  

• [Bug]: ADKAgentModelHandler fails with AlreadyExistsError when a session_id is reused

  bugP2python
  apache/beam#41299 · Filter by author alisha-1000 opened on Nov 13, 2026
  1

  

• [Bug]: Typo in IdTracker.writeValues() calls idsAvailable.clear() instead of idsAvailableValue.clear(), leaking OrderedListState ID-tracking state in Windmill

  bugP2
  apache/beam#41295 · Filter by author stankiewicz opened on Nov 13, 2026
  

• [Bug]: WindmillMultimap and WindmillMap readLater() skip in-memory cache checks, causing contagious cache-miss read amplification

  bugdataflowjavaP2
  apache/beam#41294 · Filter by author stankiewicz opened on Nov 13, 2026
  

• [Bug]: Beam YAML SQL-backed Combine generates invalid syntax for language: calcite expressions and language: sql shorthand aggregations

  P2pythonyaml
  apache/beam#41288 · Filter by author vishalmore90 opened on Nov 13, 2026
  1

  

• [Feature Request]: Add possibility of configuring per-job reservation slots in BigQueryIO connector

  ionew featureP2
  apache/beam#41287 · Filter by author mgorsk1 opened on Nov 13, 2026
  1

  

• [Bug]: DataFrame API skew() and kurtosis() raise UnboundLocalError when all the data is in one partition

  P2python
  apache/beam#41283 · Filter by author sohailshk opened on Nov 13, 2026
  1

  

• [Bug]: Spark 4 streaming runner can restore a leaf query from another leaf's checkpoint after a restart

  P1spark
  apache/beam#41254 · Filter by author tkaymak opened on Nov 12, 2026
  1

  

• [Feature Request]: SpannerIO ReadChangeStream: expose the real-time checkpoint interval as a public option (independent of withLowLatency)

  iojavaP3
  apache/beam#41251 · Filter by author igorraspopovic opened on Nov 12, 2026
  1

• Performance Regression or Improvement: gbk_python_batch_load_test_2gb_of_10B_records:runtime

  awaiting triageperf-alert
  apache/beam#41246 · Filter by author github-actions opened on Nov 12, 2026

• [Bug]: Python file-based sinks emit their output file paths at MAX_TIMESTAMP, past the end of the global window

  awaiting triagebugioP2python
  apache/beam#41245 · Filter by author jonathansudhakar1 opened on Nov 12, 2026
  1

• [Bug]: MLTransform and RAG embedding output functions modify their input elements

  bugP2python
  apache/beam#41233 · Filter by author sohailshk opened on Nov 12, 2026
  1

  

• [Bug]: MajorityVote tie_breaker ignores a custom normal_label

  bugP2python
  apache/beam#41232 · Filter by author sohailshk opened on Nov 12, 2026
  1

  

• [Feature Request]: [Lakehouse/Python] Partition-aware zero-copy metadata translation from Delta Lake to Apache Iceberg

  apache/beam#41227 · Filter by author jk-shah opened on Nov 11, 2026

• [Feature Request]: [Iceberg/Managed] Continuous unbounded streaming support in beam.managed.Write(ICEBERG) (Append & CDC)

  apache/beam#41226 · Filter by author jk-shah opened on Nov 11, 2026

• [Feature Request]: [Kafka/YAML] Turnkey Confluent Schema Registry Wire Format deserializer in ReadFromKafka

  apache/beam#41225 · Filter by author jk-shah opened on Nov 11, 2026