Issues

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

• [Feature Request]: [Streaming/YAML] Add declarative IntervalJoin composite transform with watermark skew circuit breaker

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

• [Feature Request]: [Python/YAML] Add native Expect / data quality PTransform with tagged DLQ outputs

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

• [Feature Request]: Support BigQuery reservation for Java BigQueryIO FILE_LOADS

  iojavanew featureP2
  apache/beam#41212 · Filter by author paragpratim opened on Nov 11, 2026
  1

  

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

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

  

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

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

  

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

  new featureP2pythonyaml
  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