Issues

• [Bug]: Combine with hot key fanout computes a wrong result on the Spark 4 streaming runner

  P2spark
  apache/beam#41199 · Filter by author tkaymak opened on Nov 11, 2026
  1

  

• [Bug]: Spark 4 streaming runner runs a shared upstream once per consuming branch

  P2spark
  apache/beam#41198 · Filter by author tkaymak opened on Nov 11, 2026
  1

  

• Release notes links wrong

  awaiting triagebugP3
  apache/beam#41197 · Filter by author ulsa opened on Nov 11, 2026

• [Bug]: Anthropic request functions remove max_tokens from the shared inference_args

  P2python
  apache/beam#41194 · Filter by author sohailshk opened on Nov 11, 2026

• [Bug]: MonotonicWatermarkEstimator raises TypeError when it starts without a watermark

  P2python
  apache/beam#41193 · Filter by author sohailshk opened on Nov 11, 2026

• [Feature Request]: [Python] Add Variance, StandardDeviation, Covariance, and LinearRegression to apache_beam.transforms.combiners

  P2python
  apache/beam#41171 · Filter by author jk-shah opened on Nov 10, 2026

• [Bug]: [YAML] Bugs in Join wildcard fields, empty equalities check, and test spec validation

  P2pythonyaml
  apache/beam#41164 · Filter by author LibenHailu opened on Nov 10, 2026

• [Bug]: [SolaceIO] Reader fails with StaleSessionException and cannot recover after broker disconnect

  bugiojavaP2
  apache/beam#41157 · Filter by author stankiewicz opened on Nov 10, 2026
  

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

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

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

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

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

  

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