All pull requests

Pull requests

• [Python] Accept int tags on Partition results applied to a list

  coreNext Action: Reviewerspython
  #40681·raams95 opened Oct 20, 2026Contributor·2 of 3 tasks·

  ·
  1

  2

• [Iceberg] Merge on read fixes

  icebergiojavaNext Action: Reviewers
  #40678·ahmedabu98 opened Oct 20, 2026Contributor·

  ·
  2

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

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

  ·
  1

  1

• [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: Reviewerssize/m
  #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: Reviewerspythonsize/m
  #40647·Thanatos9404 opened Oct 18, 2026·

  ·
  1

  1

• Adds bytes read reporting for SDF.

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

  ·
  12

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

• [yaml] fix documentation and tests for flags

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

  ·
  1

  5

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

  flinkNext Action: Reviewersrunnersslow-review
  #40612·jto opened Oct 15, 2026Contributor·

  ·
  6

• [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: Authorrunnerswebsite
  #40609·jto opened Oct 15, 2026Contributor·

  ·
  10

• [Flink] Re-split and balance bounded source splits in batch

  flinkNext Action: Reviewersrunnersslow-reviewwebsite
  #40608·jto opened Oct 15, 2026Contributor·2 of 3 tasks·

  ·
  9

• [Java SDK harness] Prevent a Fn data plane deadlock in BeamFnDataGrpcMultiplexer

  corejavaNext Action: Reviewersslow-review
  #40606·prodriguezdefino opened Oct 15, 2026Contributor·

  ·
  27

• [JmsIO] Let restored checkpoint marks acknowledge live messages

  iojavajmsNext Action: Reviewers
  #40605·jbonofre opened Oct 15, 2026Member·

  ·
  7

• [Python] Support Protobuf 7.x

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

  ·
  1

  6

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

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

  ·

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

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

  ·
  1

  19

• [Experimental] Update ML deps extras

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

  ·
  2

• Fix WriteToFiles not creating nested directories for file_naming paths

  coreiopython
  #40514·Akshaay1 opened Oct 12, 2026·

  ·
  1

• WIP [Rust SDK] Add the Cargo workspace, Gradle integration and model crate

  buildsize/xl
  #40508·prodriguezdefino opened Oct 11, 2026Contributor·

  ·
  14