Issues

• [Bug]: DataFrame API cov and corr diagonals ignore ddof and min_periods, and corr fails on a constant column

  P2python
  apache/beam#41139 · Filter by author anishmehta24 opened on Nov 9, 2026
  1

  

• [Bug]: [YAML] Bugs in mapping expression validation, named chain outputs, and error formatting

  P2pythonyaml
  apache/beam#41133 · Filter by author LibenHailu opened on Nov 9, 2026

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

  awaiting triagebugdataflowiojavaP2
  apache/beam#41108 · Filter by author wollowizard opened on Nov 9, 2026

• [Bug]: [Python] WriteToJson silently rounds floats to 10 decimal places

  ioP2pythonyaml
  apache/beam#41102 · Filter by author jk-shah opened on Nov 9, 2026
  1

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

  ioP2pythonyaml
  apache/beam#41101 · Filter by author jk-shah opened on Nov 9, 2026

• [Bug]: [Python] ReadFromParquet(as_rows=True) yields dicts for struct fields declared as Row

  awaiting triagebugioP2pythonyaml
  apache/beam#41100 · Filter by author jk-shah opened on Nov 9, 2026

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

  awaiting triagebugP2pythonyaml
  apache/beam#41099 · Filter by author jk-shah opened on Nov 9, 2026

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

  awaiting triagebugioP2yaml
  apache/beam#41098 · Filter by author jk-shah opened on Nov 9, 2026

• Performance Regression or Improvement: test_cloudml_benchmark_criteo_10GB-runtime_sec:runtime_sec

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

• [Bug]: ValueError messages in ml anomaly detectors and VertexAIModelHandlerJSON show a raw format string and a tuple

  P3python
  apache/beam#41087 · Filter by author sohailshk opened on Nov 8, 2026
  1

  

• [Bug]: HuggingFaceModelHandlerTensor passes inference_args instead of device to a custom inference_fn

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

  

• [Feature Request]: [YAML] Support error_handling dead-letter output on ReadFromCsv and ReadFromJson

  awaiting triagenew featureP2python
  apache/beam#41081 · Filter by author jk-shah opened on Nov 8, 2026

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

  awaiting triagebugP2pythonspark
  apache/beam#41080 · Filter by author jk-shah opened on Nov 8, 2026

• [Bug]: [Java/YAML] StringCompiler fails to resolve org.apache.beam.sdk.values.Row inside Java SDK harness container

  awaiting triagebugjavaP2
  apache/beam#41079 · Filter by author jk-shah opened on Nov 8, 2026

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

  awaiting triagebugP2python
  apache/beam#41078 · Filter by author jk-shah opened on Nov 8, 2026

• [Bug]: [Python/YAML] MapToFields / Filter expression raises SyntaxError when schema contains Python keyword column names

  bugP2python
  apache/beam#41077 · Filter by author jk-shah opened on Nov 8, 2026
  2

  

• [Bug]: [Python/Dataflow] DataflowMetrics._populate_metrics raises KeyError when only tentative or committed metric is present

  bugdataflowP2python
  apache/beam#41076 · Filter by author jk-shah opened on Nov 8, 2026
  1

  

• [Bug]: SDK container boot binary built with go1.26.2 — 13 Go stdlib CVEs (HIGH) fixed in go1.26.10, still present in 2.78.0

  P2
  apache/beam#41056 · Filter by author SlalomBrinkman opened on Nov 6, 2026
  1

  

• [Bug]: Beam YAML Join generates invalid SQL syntax (missing ON clause or forward-referenced tables) when joining 3+ inputs

  awaiting triagebugP2yaml
  apache/beam#41052 · Filter by author vishalmore90 opened on Nov 6, 2026
  1

• [Bug]: Beam YAML SQL-backed Combine generates invalid SQL syntax ("GROUP BY ") when group_by is empty or omitted

  awaiting triagebugP2yaml
  apache/beam#41047 · Filter by author vishalmore90 opened on Nov 6, 2026

• [Bug]: Spark runner ValueAndCoderLazySerializable sets bufferSize = 0 for all cheap coders due to omitted ElementByteSizeObserver.advance()

  awaiting triagebugP2spark
  apache/beam#41038 · Filter by author vishalmore90 opened on Nov 6, 2026
  1

• [Bug]: Dataflow Java worker OutputObjectAndByteCounter inflates ByteCount up to 100,000x when isRegisterByteSizeObserverCheap is true

  bugjavaP2
  apache/beam#41036 · Filter by author stankiewicz opened on Nov 6, 2026
  

• [Bug]: IcebergIO rejects timestamptz strings with a zone ID such as UTC

  bugiojavaP2
  apache/beam#41024 · Filter by author mananmangal opened on Nov 5, 2026
  1

  

• [Bug]: Beam SQL docs: the Parquet type mapping table on the CREATE EXTERNAL TABLE page is wrong

  awaiting triagebugP3website
  apache/beam#41018 · Filter by author jonathansudhakar1 opened on Nov 5, 2026
  2

  

• [Bug]: Beam SQL Parquet tables can't read DATE columns back (Joda Instant where LocalDate is expected)

  awaiting triagebugjavaP2
  apache/beam#41017 · Filter by author jonathansudhakar1 opened on Nov 5, 2026
  2