All pull requests

Pull requests

• update beam dev sdk container tag to 20261026

  Next Action: Reviewerspythonrunnerssize/xs
  #40831·derrickaw opened Oct 26, 2026Collaborator·

  ·
  2

• Managed Iceberg AddFiles

  coreicebergiojavamodelNext Action: Reviewerspythonsize/myaml
  #40827·ahmedabu98 opened Oct 26, 2026Contributor·

  ·
  5

• Beam SQL Primary Keys

  extensionsicebergiojavasize/lsql
  #40826·ahmedabu98 opened Oct 26, 2026Contributor·

  ·
  3

• Fix silent data truncation when mutating partially-cached StateIterables

  corejavaNext Action: Reviewerssize/s
  #40825·acrites opened Oct 26, 2026Contributor·

  ·
  5

• Support closures and clean hard-deletion in MultiProcessShared spawn_process (#40673)

  Next Action: Reviewerspythonsize/m
  #40822·damccorm opened Oct 26, 2026Contributor·

  ·
  3

• [Experimental] Update ONNX extras

  Next Action: Reviewerspythonsize/m
  #40821·jrmccluskey opened Oct 26, 2026Contributor·

  ·
  4

• [#18690] Port SolrIOTest off deprecated DoFnTester

  iojavaNext Action: Reviewerssize/ssolr
  #40819·Supersaiyan101 opened Oct 26, 2026·4 tasks done·

  ·
  1

  2

• AddFiles: Wire a destination-table key through the registration chain

  icebergiojavaNext Action: Reviewerssize/m
  #40817·claudevdm opened Oct 26, 2026Collaborator·

  ·
  2

• Spawn MultiProcessShared RunInference models in dedicated processes (#40673)

  pythonsize/m
  #40816·damccorm opened Oct 26, 2026Contributor·

  ·

• Fix PreCommit Java Solace IO Direct workflow

  buildNext Action: Reviewerssize/xs
  #40815·Amar3tto opened Oct 26, 2026Collaborator·

  ·
  1

  3

• [Dataflow Streaming] Avoid LinkedBlockingQueue.removeIf data race in BoundedQueueExecutor

  dataflowrunnerssize/s
  #40812·damccorm opened Oct 26, 2026Contributor·

  ·
  4

• Update Python container CA dependencies and distroless base images to debian13

  dockergojavaNext Action: Reviewerspythonsize/s
  #40811·damccorm opened Oct 26, 2026Contributor·

  ·
  4

• Upgrade Gradle Build Compatibility for Gradle 9 and JDK 25

  awsbigtablebuildclickhousecoredataflowexamplesextensionsflinkfn-executiongcpgoiceberginfraiojavakafkakotlinlearningpythonrunnerssize/xlspannersparksqlzetasketch
  #40810·alisha-1000 opened Oct 26, 2026Contributor·

  ·
  10

• [Spanner Change Stream] Make InitializeDoFn fake parent partition creation idempotent

  gcpiojavasize/mspanner
  #40808·jiangzzhu opened Oct 26, 2026Contributor·

  ·

• [Python] Preserve argument binding for defaulted DoFn elements

  Next Action: Authorpythonrunnerssize/s
  #40798·xgbtxy opened Oct 26, 2026·

  ·
  1

  6

• [SpannerIO] Add UUID and ARRAY<UUID> support for mutations, structs and change streams

  gcpiojavaNext Action: Reviewerssize/mspanner
  #40797·kylase opened Oct 26, 2026·

  ·
  9

• Resolve staged sklearn model path on the worker in RunInference xlang tests

  extensionsgojavasize/s
  #40795·tarun-google opened Oct 26, 2026Contributor·

  ·
  1

• Retry transient errors in BigqueryClient.queryUnflattened

  gcpiojavaNext Action: Reviewerssize/m
  #40793·mxtymoshyk opened Oct 25, 2026Contributor·

  ·
  1

  1

• Optimize Row construction, RowWithGetters field caching, and Row utilities

  corejavasize/xl
  #40791·sjvanrossum opened Oct 25, 2026Contributor·

  ·
  1

• [Java] BigQueryIO: support integer-range partitioning in Write

  dataflowgcpiojavaNext Action: Reviewersrunnerssize/xl
  #40790·mxtymoshyk opened Oct 25, 2026Contributor·

  ·
  1

  7

• Fix Row equality/hashing, RowUtils validation and ByteBuffer handling, and LogicalTypeCoder DATETIME conversion

  corejavasize/m
  #40789·sjvanrossum opened Oct 25, 2026Contributor·

  ·
  1

• Prevent Fn data plane deadlock via non-blocking CancellableQueue.add and gRPC inbound flow control

  corejavaNext Action: Reviewerssize/xl
  #40788·sjvanrossum opened Oct 25, 2026Contributor·

  ·
  12

• [Spark] Resolve the structured streaming pipeline state from the execution, cancel() returns the observed state

  runnerssize/mspark
  #40787·tkaymak opened Oct 25, 2026Contributor·

  ·
  1

  2

• [DebeziumIO] Support Transaction Metadata Events in DebeziumIO JSON Output

  goiojavaNext Action: Reviewerspythonsize/m
  #40785·ilyasahsan123 opened Oct 25, 2026Contributor·1 of 4 tasks·

  ·
  10

• [InfluxDB] Wait for HTTP readiness before integration tests

  buildsize/s
  #40783·bvolpato opened Oct 25, 2026Contributor·

  ·