All pull requests

Pull requests

• Backport #40996 into 2.77.0-postrelease branch

  dockerpythonsize/s
  #41055·Abacn opened Nov 6, 2026Contributor·

  ·
  4

• Use side inputs to implement non-compressing to singleton global combines.

  corepythonsize/m
  #41054·robertwb opened Nov 6, 2026Contributor·

  ·
  3

• [Python][RunInference] Deduplicate ModelHandler wrappers via _DelegatingModelHandler

  pythonsize/m
  #41051·damccorm opened Nov 6, 2026Contributor·

  ·
  1

• Update managed-io.md for release 2.78.0-RC2

  size/lwebsite
  #41050·jrmccluskey opened Nov 6, 2026Contributor·

  ·

• [YAML] Fix SQL-backed Combine generating invalid syntax when group_by is empty or omitted

  Next Action: Reviewerspythonsize/syaml
  #41049·vishalmore90 opened Nov 6, 2026Contributor·

  ·
  1

  4

• Exp

  buildpythonrunnerssize/s
  #41048·asheshvidyut opened Nov 6, 2026·

  ·
  1

• Wait for Flink mini cluster REST server before submitting uber jar

  Next Action: Reviewersportabilityrunnerssize/s
  #41046·damccorm opened Nov 6, 2026Contributor·

  ·
  7

• [Python/YAML] Accept >=, <=, == and != in generic Filter expressions …

  Next Action: Reviewerspythonsize/syaml
  #41044·jk-shah opened Nov 6, 2026Contributor·

  ·
  1

  1

• [Website] Use go run @latest for the Go commands in the WordCount walkthrough

  Next Action: Reviewerssize/swebsite
  #41041·jonathansudhakar1 opened Nov 6, 2026Contributor·

  ·
  1

  1

• [Python] Add beam pipe to the experimental beam command (#40891)

  Next Action: Reviewerspythonsize/l
  #41040·jk-shah opened Nov 6, 2026Contributor·

  ·
  5

• [Spark] Fix zero buffer size in ValueAndCoderLazySerializable for cheap coders

  Next Action: Reviewersrunnerssize/sspark
  #41039·vishalmore90 opened Nov 6, 2026Contributor·

  ·
  1

  2

• Harden Spark and Flink state execution tests against PreCommit Java load

  flinkNext Action: Reviewersrunnerssize/sspark
  #41037·damccorm opened Nov 6, 2026Contributor·

  ·
  3

• Support java_gc experiment in Java SDK harness container

  dockerjavaNext Action: Reviewerssize/s
  #41029·Abacn opened Nov 5, 2026Contributor·

  ·
  3

• [Dataflow] Reduce ShuffleSinkWriter memory retention and eagerly free native ApplianceShuffleWriter

  dataflowNext Action: Authorrunnerssize/s
  #41028·Abacn opened Nov 5, 2026Contributor·

  ·
  2

• Fix IcebergIO rejecting timestamptz strings with a zone ID

  icebergiojavaNext Action: Reviewerssize/m
  #41027·mananmangal opened Nov 5, 2026Contributor·

  ·
  1

  4

• Fix GroupIntoBatches validation, display data, empty batch flush, and timestamp overflow.

  corejavaNext Action: Reviewerssize/s
  #41023·acrites opened Nov 5, 2026Contributor·

  ·
  8

• [Go] Fix metrics incremented in Setup not being recalled

  coregoNext Action: Reviewerssize/m
  #41021·xh123637 opened Nov 5, 2026·2 tasks done·

  ·
  1

  1

• [Java] Support cross-chunk element decoding in UncachedStateIterable

  corejavaNext Action: Reviewerssize/m
  #41020·acrites opened Nov 5, 2026Contributor·

  ·
  5

• [Website] Fix the Parquet type mapping table for Beam SQL CREATE EXTERNAL TABLE

  Next Action: Reviewerssize/swebsite
  #41019·jonathansudhakar1 opened Nov 5, 2026Contributor·

  ·
  1

  7

• use Python 3.12 for TensorRT benchmarks

  buildNext Action: Reviewerssize/s
  #41014·aIbrahiim opened Nov 5, 2026Contributor·

  ·
  2

• [JmsIO] Acknowledge messages of checkpoints that are never finalized

  coreiojavajmsNext Action: Reviewerssize/l
  #41013·jbonofre opened Nov 5, 2026Member·

  ·
  6

• [IcebergIO] Fix partition values written by hash distribution

  icebergiojavaNext Action: Reviewerssize/m
  #41012·ahmedabu98 opened Nov 5, 2026Contributor·

  ·
  2

• [Beam SQL] Fix column swaps and table show

  extensionsicebergjavaNext Action: Reviewerssize/ssql
  #41007·ahmedabu98 opened Nov 5, 2026Contributor·

  ·
  2

• [Java] Make ServerFactory listen on the requested host

  corefn-executionjavarunnerssize/m
  #41006·bvolpato opened Nov 5, 2026Contributor·

  ·

• [Python] Upgrade the vLLM extra to 0.32.0

  dockerpythonsize/m
  #41005·bvolpato opened Nov 5, 2026Contributor·

  ·
  1