All pull requests

Pull requests

• Scope RunInference model_identifier annotation and preserve ModelManager metric_tag across model updates

  python
  #40671·AMOOOMA opened Oct 19, 2026Contributor·

  ·

• Upgrade google-api-client to 2.7.2

  builddataflowrunners
  #40670·shunping opened Oct 19, 2026Collaborator·

  ·
  3

• Add retries and timeout to Grafana request in flaky test detection

  infraNext Action: Reviewers
  #40669·schizophrenicmaniac opened Oct 19, 2026Contributor·

  ·
  1

  1

• Fix Release NightlySnapshot after enabling errorprone for Java17+ build

  deltaiojava
  #40668·Abacn opened Oct 19, 2026Contributor·

  ·
  1

  2

• [RunInference] Honor model updates in also in the first batch.

  Next Action: Reviewerspython
  #40667·tvalentyn opened Oct 19, 2026Contributor·

  ·
  1

  7

• Allow canceling SQL streaming pipeline

  extensionsjavaNext Action: Reviewerssql
  #40666·ahmedabu98 opened Oct 19, 2026Contributor·

  ·
  3

• Remove Beam SQL Data Catalog provider

  buildextensionsjavasql
  #40663·aIbrahiim opened Oct 19, 2026Contributor·

  ·
  1

  4

• [yaml] - add openai model handler

  pythonyaml
  #40658·derrickaw opened Oct 19, 2026Collaborator·

  ·
  1

• Document Beam Playground security model and result caching

  website
  #40657·damccorm opened Oct 19, 2026Contributor·

  ·

• [IcebergIO] Support sorted writes and RANGE distribution mode

  icebergiojavaNext Action: Reviewerswebsite
  #40653·atognolag opened Oct 19, 2026Contributor·

  ·
  3

• [Go SDK] Fix generic registration of anonymous struct types

  goNext Action: Reviewers
  #40649·Thanatos9404 opened Oct 18, 2026·

  ·
  1

  2

• [DoNotMerge] Adds CouchbaseIO, a Java connector for Couchbase Server. Fixes #18381 [DonNotMerge]

  buildiojavawebsite
  #40648·nitinware opened Oct 18, 2026Contributor·3 of 4 tasks·

  ·
  1

  3

• [Python] Only give an unknown option a value that directly follows it

  Next Action: Reviewerspython
  #40647·Thanatos9404 opened Oct 18, 2026·

  ·
  1

  1

• Only feed total memory readings to the ModelManager resource estimator

  Next Action: Reviewerspython
  #40646·schizophrenicmaniac opened Oct 17, 2026Contributor·

  ·
  1

  4

• Adds bytes read reporting for SDF.

  dataflowNext Action: Reviewersrunners
  #40639·acrites opened Oct 16, 2026Contributor·

  ·
  2

• [Dataflow Streaming] Speed up non-portable worker precommit tests

  dataflowrunners
  #40637·arunpandianp opened Oct 16, 2026Contributor·

  ·
  1

• [Python] Add Qdrant search enrichment handler

  Next Action: Reviewerspython
  #40629·pangwangshu opened Oct 16, 2026Contributor·

  ·
  1

  10

• [BEAM-19954] Resolve string annotations in callable type hints

  coreNext Action: Authorpython
  #40625·Gaurav598 opened Oct 16, 2026Contributor·

  ·
  1

  15

• add WRITE_TRUNCATE_DATA write_disposition to the bigquery python sdk

  gcpiojavaNext Action: Authorpython
  #40622·GaryPWhite opened Oct 15, 2026·

  ·
  9

• Trigger BQ CDC IT. Fix impl

  gcpiopython
  #40618·claudevdm opened Oct 15, 2026Collaborator·

  ·
  1

• [yaml] fix documentation and tests for flags

  Next Action: Reviewerspythonwebsiteyaml
  #40617·derrickaw opened Oct 15, 2026Collaborator·

  ·
  1

  3

• [yaml] move pipeline examples from blueprint to pipelines

  Next Action: Reviewerspythonyaml
  #40615·derrickaw opened Oct 15, 2026Collaborator·

  ·
  3

• [Flink] Reshuffle batch inputs round-robin from deterministic start channels

  flinkNext Action: Reviewersrunners
  #40612·jto opened Oct 15, 2026Contributor·

  ·
  5

• [Flink] Add a dedicated operator for batch combines in the global window

  flinkrunnerswebsite
  #40611·jto opened Oct 15, 2026Contributor·

  ·
  2

• [Flink] Copy length-prefixed batch records and decode grouping inputs lazily

  flinkNext Action: Reviewersrunnerswebsite
  #40609·jto opened Oct 15, 2026Contributor·

  ·
  8