All pull requests

Pull requests

• Fix JmsIO finalize removal warning and clean up stale Java version logic

  buildiojavajms
  #40595·Abacn opened Oct 14, 2026Contributor·

  ·
  2

• [Multikey] [Dataflow Streaming] Replace KeyGroupWorkQueue with a sharded KeyGroupIndex

  dataflowrunners
  #40593·arunpandianp opened Oct 14, 2026Contributor·

  ·
  5

• Add examples for AWS credentials from a secret manager

  awscoreexamplesiopython
  #40592·shunping opened Oct 14, 2026Collaborator·

  ·
  3

• Bump minimum cryptography bounds beyond known severe CVEs

  Next Action: Reviewerspython
  #40591·jrmccluskey opened Oct 14, 2026Contributor·

  ·
  2

• update node in workflows to 24

  buildNext Action: Reviewers
  #40590·derrickaw opened Oct 14, 2026Collaborator·

  ·
  2

• Fix handling of cancelled tickets.

  python
  #40588·tvalentyn opened Oct 14, 2026Contributor·

  ·
  3

• [yaml] - fix spanner configs and examples

  gcpiojavaNext Action: Reviewerspythonspanneryaml
  #40587·derrickaw opened Oct 14, 2026Collaborator·

  ·
  3

• [Python] Support Protobuf 7.x

  Next Action: Reviewerspython
  #40581·sofiathoren opened Oct 14, 2026·1 of 3 tasks·

  ·
  1

  2

• [OpenTelemetry] Resolve inline Secret placeholders in openTelemetryProperties

  corejava
  #40579·stankiewicz opened Oct 14, 2026Contributor·

  ·
  1

• Update Trivial Inference for Python 3.15

  coreNext Action: Reviewerspython
  #40578·jrmccluskey opened Oct 14, 2026Contributor·

  ·
  2

• Keep latest metrics image tags updated and set commit image tags after kubectl apply

  infra
  #40577·damccorm opened Oct 14, 2026Contributor·

  ·

• Update FlareDB runner doc

  Next Action: Reviewerswebsite
  #40576·ganesh-skumar opened Oct 14, 2026Contributor·

  ·
  2

• [RunInference] Reject use_model_manager with a multi-model KeyedModelHandler

  Next Action: Reviewerspython
  #40574·schizophrenicmaniac opened Oct 14, 2026Contributor·

  ·
  1

  5

• [Python] Handle NaN in DataFrame drop_duplicates, duplicated and nunique

  Next Action: Reviewerspython
  #40571·anishmehta24 opened Oct 14, 2026Contributor·

  ·
  1

  2

• [Python] Don't override the Dataflow endpoint by default

  Next Action: Reviewerspythonrunners
  #40568·shunping opened Oct 14, 2026Collaborator·

  ·
  7

• [Python] Return every group from Regex.all_matches

  coreNext Action: Reviewerspython
  #40563·raams95 opened Oct 13, 2026·2 of 3 tasks·

  ·
  1

  4

• Modernize legacy DoFn in BatchElementsExample (#40557)

  examplesjavaNext Action: Reviewers
  #40560·CH-Abhinav opened Oct 13, 2026·

  ·
  1

  1

• poll BigQuery matchers on missing tables

  buildgcpioNext Action: Reviewerspython
  #40559·aIbrahiim opened Oct 13, 2026Contributor·

  ·
  1

  6

• [Python] Add AwsSecret to the Secret utility

  awscoreioNext Action: Reviewerspython
  #40558·shunping opened Oct 13, 2026Collaborator·

  ·
  2

• Replace typing.ByteString with collections.abc.Buffer

  coregcpioNext Action: Reviewerspython
  #40554·jrmccluskey opened Oct 13, 2026Contributor·

  ·
  2

• [Spark 4] Clear the watermark of keys without timers or state in the streaming stateful ParDo

  Next Action: Reviewersrunnersspark
  #40550·schizophrenicmaniac opened Oct 13, 2026Contributor·

  ·
  1

  4

• [Python] Avoid ZeroDivisionError in ConcatRangeTracker for zero weights

  ioNext Action: Reviewerspython
  #40549·raams95 opened Oct 13, 2026·2 of 3 tasks·

  ·
  1

  5

• [Python] Keep Nexmark Query 1 bid prices as integers

  buildNext Action: Reviewerspython
  #40548·raams95 opened Oct 13, 2026·2 of 3 tasks·

  ·
  1

  8

• [WriteFiles] Support direct writes of large streaming bundles to temp files (#40533)

  coredataflowjavaNext Action: Reviewersrunners
  #40543·tejasiyer-dev opened Oct 13, 2026Contributor·

  ·
  1

  10

• [Experimental] Update ML deps extras

  python
  #40531·jrmccluskey opened Oct 12, 2026Contributor·

  ·
  2