Issues

• Kafka Streams runner: splittable DoFn

  apache/beam#39631 · Filter by author junaiddshaukat opened on Aug 5, 2026

• Kafka Streams runner: merging windows and custom WindowFns

  apache/beam#39630 · Filter by author junaiddshaukat opened on Aug 5, 2026

• Kafka Streams runner: stateful ParDo and user timers

  apache/beam#39629 · Filter by author junaiddshaukat opened on Aug 5, 2026

• Kafka Streams runner: side inputs

  apache/beam#39628 · Filter by author junaiddshaukat opened on Aug 5, 2026

• Kafka Streams runner: read a source's splits in parallel

  apache/beam#39626 · Filter by author junaiddshaukat opened on Aug 5, 2026

• Upgrade vendored grpc to remove vulnerabilities coming from netty

  apache/beam#39624 · Filter by author milindl opened on Aug 5, 2026

• [Task]: Investigate native ARM runners for Python aarch64 wheels

  awaiting triageinfraP2pythontask
  apache/beam#39620 · Filter by author bvolpato opened on Aug 5, 2026

• [Bug]: SolaceIO write transform does not output all publish results

  awaiting triagebugdataflowioP2
  apache/beam#39588 · Filter by author ppawel opened on Aug 3, 2026

• [Task]: Set the Beam user agent on the Python boto3 S3 client

  P3
  apache/beam#39573 · Filter by author goanpeca opened on Jul 31, 2026
  1

  

• Upgrade DebeziumIO to Debezium 3.5.2.Final

  iojavaP2
  apache/beam#39568 · Filter by author tkaymak opened on Jul 31, 2026
  2

• Kafka Streams runner: lifecycle management for runner-created topics

  apache/beam#39566 · Filter by author junaiddshaukat opened on Jul 31, 2026

• Kafka Streams runner: expose topic-level configuration for runner-created topics

  apache/beam#39565 · Filter by author junaiddshaukat opened on Jul 31, 2026

• [Bug]: Performance regression and stuck jobs due to gcs-connector v3 upgrade

  awaiting triagebugjavaP2
  apache/beam#39548 · Filter by author shunping opened on Jul 29, 2026

• [GSoC 2026] Kafka Streams runner: un-sickbay ParDoTest$LifecycleTests.testParDoWithErrorInStartBatch

  apache/beam#39452 · Filter by author junaiddshaukat opened on Jul 23, 2026

• [Feature Request]: OpenLineage extension for the Java SDK

  javaP2
  apache/beam#39427 · Filter by author rahul-madaan opened on Jul 22, 2026

• [Bug]: Cached ContinuationIterable permanently poisons state reads after its continuation token becomes invalid

  dataflowP2python
  apache/beam#39383 · Filter by author addenergyx opened on Jul 19, 2026
  1

  

• [Kafka Streams runner] Use a single Impulse bootstrap topic with fan-out

  apache/beam#39382 · Filter by author junaiddshaukat opened on Jul 19, 2026
  1

  

• [Bug]: Bounded Java WriteFiles finalization materializes all FileResults as a global side input

  dataflowiojavaP2
  apache/beam#39370 · Filter by author ntopousis opened on Jul 17, 2026
  2

  

• [Bug]: job launch problem 2.75.0

  awaiting triagebugjavaP2
  apache/beam#39353 · Filter by author aprochko opened on Jul 16, 2026
  5

• [Feature Request]: Expand the info provided in Beam Python's heap dump

  awaiting triagenew featureP2
  apache/beam#39244 · Filter by author tvalentyn opened on Jul 8, 2026

• [Task]: Update mheap version to include Node 24 support

  infraP2task
  apache/beam#39238 · Filter by author derrickaw opened on Jul 7, 2026
  1

  

• [Feature Request]: Add Delete Orphan Files operation in Iceberg

  IcebergIOiojavanew featureP2
  apache/beam#39225 · Filter by author ahmedabu98 opened on Jul 6, 2026
  

• [Feature Request]: Add Expire Snapshots maintenance in Iceberg

  IcebergIOiojavanew featureP2
  apache/beam#39224 · Filter by author ahmedabu98 opened on Jul 6, 2026
  

• [Feature Request]: Add Manifest File compaction in Iceberg

  new featureP2
  apache/beam#39222 · Filter by author ahmedabu98 opened on Jul 6, 2026
  

• [Feature Request]: Add DataFile compaction in Iceberg

  iojavanew featureP2
  apache/beam#39221 · Filter by author ahmedabu98 opened on Jul 6, 2026
  1