Issues

• [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

  

• [Failing Test]: JmsIOTest.testAuthenticationWithBadPassword is flaky (ActiveMQ)

  flakeiojavaP2tests
  apache/beam#40289 · Filter by author mxtymoshyk opened on Sep 25, 2026
  2

  

• [Bug]: Python ParquetIO _WriteBatches DoFn silently corrupts data across windows in unbounded pipelines

  awaiting triagebugP2python
  apache/beam#40284 · Filter by author vishalmore90 opened on Sep 25, 2026
  1

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

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

• [Spark] SparkStateInternals: MapState and SetState isEmpty() stays false after removing the last element

  apache/beam#40264 · Filter by author tkaymak opened on Sep 24, 2026
  2

• [Bug]: Duration(float seconds) truncates instead of rounding, losing a microsecond

  P3python
  apache/beam#40263 · Filter by author anishmehta24 opened on Sep 24, 2026
  1

  

• [Task]: Remove support for Python 3.10

  P2pythontask
  apache/beam#40250 · Filter by author jrmccluskey opened on Sep 23, 2026
  2

• [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]: Unrecoverable Runner Errors (CommitTooLargeException) When Emitting High Volume of Duplicate/Unprocessed Events in OrderedEventProcessor

  bugdataflowjavaP2
  apache/beam#40240 · 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]: Update Beam Grafana instance

  infranew featureP2
  apache/beam#40215 · Filter by author tvalentyn opened on Sep 21, 2026
  1

• [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

  

• [Feature Request]: Avoid per-field Descriptor.findFieldByName lookups in BigQuery Storage Write API TableRow conversion

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

  

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

  new featureP2python
  apache/beam#40179 · Filter by author damccorm opened on Sep 18, 2026
  

• [Feature Request]: SolaceIO: Add OpenTelemetry Distributed Tracing Support

  iojavanew featureP2
  apache/beam#40175 · Filter by author stankiewicz opened on Sep 18, 2026
  3

  

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

  goP2
  apache/beam#40159 · Filter by author Eliaaazzz opened on Sep 17, 2026
  1

  

• [Bug]: Go SDK row coder encodes INT16 schema fields as varint instead of big endian

  goP2
  apache/beam#40151 · Filter by author Eliaaazzz opened on Sep 17, 2026

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

  apache/beam#40120 · Filter by author tkaymak opened on Sep 14, 2026
  4

• [Bug]: BigQueryIO Storage Write API failed-rows output crashes: TIMESTAMP printed with both a space and a T separator, then parsed by Instant.parse

  awaiting triagebugdataflowiojavaP2python
  apache/beam#40110 · Filter by author JazzFan opened on Sep 13, 2026
  2

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

  iojavanew featureP2
  apache/beam#40086 · Filter by author nitinware opened on Sep 9, 2026
  1

  

• [Feature Request]: Improve exception visibility in FileSystems.matchSingleFileSpec to prevent masking of root-cause Exceptions

  iojavanew featureP2
  apache/beam#40076 · Filter by author sharan-malyala opened on Sep 9, 2026
  2

  

• Performance Regression or Improvement: test_cloudml_benchmark_cirteo_no_shuffle_10GB-runtime_sec:runtime_sec

  awaiting triageperf-alert
  apache/beam#40067 · Filter by author github-actions opened on Sep 8, 2026
  1