All pull requests

Pull requests

• Fix Dataflow Validate runner test flakiness for streaming tests

  dataflowrunnerssize/s
  #40952·Abacn opened Nov 2, 2026Contributor·

  ·
  2

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

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

  ·
  8

• [Website] Remove stray space before commas in blog post author lists

  Next Action: Reviewerssize/xswebsite
  #40948·jonathansudhakar1 opened Nov 2, 2026·

  ·
  1

  1

• Update CHANGES.md add subsection for Improvement and Breaking change section

  size/m
  #40947·Abacn opened Nov 2, 2026Contributor·

  ·
  2

• 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

• [#36841] Spark 4 streaming: detached reader for sibling scans of one source

  runnerssize/mspark
  #40932·tkaymak opened Nov 1, 2026Contributor·

  ·
  2

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

  3

• Validate the SlidingWindows period in the Python SDK

  coreNext Action: Reviewerspythonsize/s
  #40925·jayyyyqwq opened Oct 31, 2026·

  ·
  5

• Attach RunInference model_identifier only to the inference ParDo with exception handling

  coreNext Action: Reviewerspythonsize/m
  #40922·Brijesh-Thakkar opened Oct 31, 2026·2 of 4 tasks·

  ·
  1

  2

• Port ReadSpannerSchemaTest off deprecated DoFnTester

  gcpiojavaNext Action: Reviewerssize/s
  #40921·Supersaiyan101 opened Oct 31, 2026Contributor·

  ·
  2

• [yaml] - update enrichment testing

  pythonsize/myaml
  #40916·derrickaw opened Oct 30, 2026Collaborator·

  ·
  1

• [yaml] - include yaml and tfrecord extras in py311-cloudcoverage

  pythonsize/xs
  #40912·derrickaw opened Oct 30, 2026Collaborator·

  ·
  2

• Fix broken GlobalWindow singleton

  coreNext Action: Reviewerspythonsize/xs
  #40910·Abacn opened Oct 30, 2026Contributor·

  ·
  3

• [#18690] Port Iceberg IO tests off deprecated DoFnTester

  icebergiojavaNext Action: Reviewerssize/m
  #40909·Supersaiyan101 opened Oct 30, 2026Contributor·

  ·
  7

• [Python][RunInference] vLLM: prefix-aware batching and capacity-based autoscaling

  corepythonsize/xl
  #40908·AMOOOMA opened Oct 30, 2026Contributor·3 tasks done·

  ·
  1

• [Python][RunInference] Add a capacity-based autoscaling signal for model-server handlers

  pythonsize/l
  #40907·AMOOOMA opened Oct 30, 2026Contributor·2 of 3 tasks·

  ·
  1

• [Python][RunInference] Report the model identifier to model handlers

  pythonsize/s
  #40906·AMOOOMA opened Oct 30, 2026Contributor·2 of 3 tasks·

  ·
  3

• [Python][RunInference] Add prefix-aware batching across workers

  corepythonsize/l
  #40905·AMOOOMA opened Oct 30, 2026Contributor·3 tasks done·

  ·
  3

• [Java] Improve ProtoCoder decode error for raw Message type

  extensionsjavaNext Action: Reviewersprotobufsize/s
  #40904·Brijesh-Thakkar opened Oct 30, 2026·

  ·
  2