All pull requests

Pull requests

• [Prism] Fix flaky TestPersistBundle_ResidualResumeDelay bound

  goNext Action: Reviewersprismrunnerssize/xs
  #40993·jonathansudhakar1 opened Nov 4, 2026Contributor·

  ·
  1

  5

• [Go] Support context.Context in register.CombinerN methods

  goNext Action: Reviewerssize/l
  #40991·jonathansudhakar1 opened Nov 4, 2026Contributor·

  ·
  1

  1

• [#36841] Announce Spark 4 Structured Streaming runner streaming support in CHANGES.md

  size/xs
  #40990·tkaymak opened Nov 4, 2026Contributor·

  ·
  2

• [Website] Fix and complete the RunInference metrics definitions

  Next Action: Reviewerssize/swebsite
  #40986·tannnmayy opened Nov 4, 2026Contributor·

  ·
  1

  1

• [SolaceIO] Route persistent write ACKs to the owning bundle

  iojavaNext Action: Reviewerssize/l
  #40985·stankiewicz opened Nov 4, 2026Contributor·

  ·

  · 2.78.0 Release
  1

  8

• [Go] Add optional random access to the filesystem API

  coregoioNext Action: Reviewerssize/xl
  #40983·goutamadwant opened Nov 4, 2026Contributor·

  ·
  1

• Add CHANGES function to Beam SQL

  extensionsicebergjavaNext Action: Reviewerssize/xlsql
  #40982·ahmedabu98 opened Nov 4, 2026Contributor·

  ·
  7

• [IcebergIO] Sort CDC sink windows with the native sorter

  extensionsicebergiojavaNext Action: Reviewerssize/ssorter
  #40980·ahmedabu98 opened Nov 4, 2026Contributor·

  ·
  1

• Move BundleLifter from Iceberg to sdk/util

  coreicebergiojavaNext Action: Reviewerssize/s
  #40978·tejasiyer-dev opened Nov 3, 2026Contributor·

  ·
  1

• [Spanner Change Stream] Add diagnostic logging when partition discovery stops

  gcpiojavasize/mspanner
  #40977·jiangzzhu opened Nov 3, 2026Contributor·

  ·

• [Prism] Fix GroupIntoBatches losing or misframing batches

  goNext Action: Reviewersprismrunnerssize/m
  #40975·ahmedabu98 opened Nov 3, 2026Contributor·

  ·
  2

• Add Credit Karma ML model explainability case study

  Next Action: Reviewerssize/mwebsite
  #40974·04pallav opened Nov 3, 2026·

  ·
  2

• Update opentelemetry package version constraints

  Next Action: Reviewerspythonsize/xs
  #40973·aebrahim opened Nov 3, 2026Contributor·

  ·
  2

• [Python] Add an experimental beam command with beam run #40891

  Next Action: Reviewerspythonsize/l
  #40968·jk-shah opened Nov 3, 2026·

  ·
  1

• [Python] Fix WriteToFiles crashing when the sink writes compressed files

  coreioNext Action: Reviewerspythonsize/s
  #40966·PDGGK opened Nov 3, 2026Contributor·

  ·
  1

  4

• [Dataflow Streaming] [MultiKey] Handle work cancellation exceptions in WorkFailureProcessor.

  dataflowrunnerssize/m
  #40955·arunpandianp opened Nov 2, 2026Contributor·

  ·
  5

• Add ParDoFn.getDoFnInfo and rename internal getDoFnInfo to getActiveDoFnInfo.

  dataflowrunnerssize/m
  #40951·acrites opened Nov 2, 2026Contributor·

  ·
  14

• Update Beam website to release 2.78.0

  size/mwebsite
  #40946·Amar3tto opened Nov 2, 2026Collaborator·

  ·

• [Go] Avoid importing jobopts in xlangx to prevent flag collisions

  coregoNext Action: Reviewerssize/m
  #40944·PDGGK opened Nov 2, 2026Contributor·

  ·
  1

  5

• [Spanner Change Streams] Replay aborted metadata transactions

  gcpiojavaNext Action: Reviewerssize/mspanner
  #40937·bvolpato opened Nov 2, 2026Contributor·

  ·
  1

• [Spanner Change Streams] Fix arrival order assumption in ordered IT

  gcpiojavaNext Action: Reviewerssize/s
  #40936·bvolpato opened Nov 2, 2026Contributor·

  ·
  1

• Clarify Beam initialization requirements in Go

  coregoNext Action: Reviewerssize/s
  #40935·huong8373tt-beep opened Nov 1, 2026·1 task·

  ·
  1

  1

• [RunInference] Raise when a model handler returns fewer predictions than inputs

  Next Action: Reviewerspythonsize/m
  #40929·tannnmayy opened Oct 31, 2026Contributor·

  ·
  1

  2

• Support PyArrow 26 in the Python SDK

  Next Action: Reviewerspythonsize/s
  #40927·Anurag-S1ngh opened Oct 31, 2026·

  ·
  1

  1

• [#34613] Fix SqlTransformSchemaTransformProvider config schema for cross-language use

  coreextensionsjavaNext Action: Reviewerspythonsize/msql
  #40926·Brijesh-Thakkar opened Oct 31, 2026·

  ·
  1

  10