All pull requests

Pull requests

• [Python] Expand PGBKCVOperation docstring

  pythonrunnerssize/s
  #41337·Anurag-S1ngh opened Nov 14, 2026Contributor·

  ·

• [CI] Build aarch64 Python wheels on native arm64 runners

  buildsize/s
  #41336·Anurag-S1ngh opened Nov 14, 2026Contributor·

  ·
  1

• [Python] ReadFromJson reads nested values as valid JSON

  ioNext Action: Reviewerspythonsize/s
  #41335·Anurag-S1ngh opened Nov 14, 2026Contributor·

  ·
  1

  1

• [Python] Infer NamedTuple and nullable nested row attribute types

  coreNext Action: Reviewerspythonsize/s
  #41334·Anurag-S1ngh opened Nov 14, 2026Contributor·

  ·
  1

  4

• Fix Milvus client reuse in write DoFn

  Next Action: Reviewerspythonsize/m
  #41333·shahithmohamed202-collab opened Nov 14, 2026·

  ·
  1

• [Python] Support process_batch-only DoFns in BundleBasedDirectRunner

  ioNext Action: Reviewerspythonrunnerssize/s
  #41332·Anurag-S1ngh opened Nov 14, 2026Contributor·

  ·
  1

  5

• [DebeziumIO] Enable Schema Change Events in DebeziumIO JSON Output

  iojavaNext Action: Authorsize/m
  #41331·ilyasahsan123 opened Nov 14, 2026Contributor·4 tasks·

  ·
  4

• Support BigQuery load job reservations in Java BigQueryIO

  gcpiojavaNext Action: Reviewerssize/l
  #41329·paragpratim opened Nov 14, 2026·

  ·
  1

  10

• Fix: Set idLabel on messages written by the batch Pub/Sub sink

  dataflowNext Action: Reviewersrunnerssize/m
  #41328·Naman-Katiyar opened Nov 14, 2026·

  ·
  1

  5

• [Python] Strip whitespace in BigQuery string schema field types

  gcpioNext Action: Reviewerspythonsize/s
  #41327·namanraii opened Nov 14, 2026·

  ·
  1

  1

• Bump pillow from 12.3.0 to 13.0.0 in /sdks/python/apache_beam/examples/ml-orchestration/kfp/components/preprocessing

  dependenciesexamplesNext Action: Reviewerspythonsize/xs
  #41326·dependabot[bot] opened Nov 13, 2026Bot·

  ·
  3

• add zizmor retries in workflow

  buildNext Action: Reviewerssize/s
  #41325·derrickaw opened Nov 13, 2026Collaborator·

  ·
  2

• update TLDR to be more important in /summarize-failures

  buildNext Action: Reviewerssize/xs
  #41323·derrickaw opened Nov 13, 2026Collaborator·

  ·
  2

• [Python] Fix DataFrame groupby on a categorical column

  Next Action: Reviewerspythonsize/s
  #41322·anishmehta24 opened Nov 13, 2026Contributor·

  ·
  1

  1

• [Python] Fix the output type hints of Reify.Window, WindowInValue and TimestampInValue

  coreNext Action: Reviewerspythonsize/s
  #41320·sohailshk opened Nov 13, 2026Contributor·

  ·
  1

  1

• [Python] Fix the proxies of DataFrame groupby describe and skew

  Next Action: Reviewerspythonsize/s
  #41319·sohailshk opened Nov 13, 2026Contributor·

  ·
  2

  1

• [Python] Document and fix the file paths output by file-based sinks

  ioNext Action: Reviewerspythonsize/m
  #41318·jonathansudhakar1 opened Nov 13, 2026Contributor·

  ·
  2

  1

• [IcebergIO] Fail when attempting to write unknown types

  icebergiojavaNext Action: Reviewerssize/s
  #41317·ahmedabu98 opened Nov 13, 2026Contributor·

  ·
  2

• [IcebergIO] Read NaN partition values from the JSON partition

  icebergiojavaNext Action: Reviewerssize/m
  #41316·ahmedabu98 opened Nov 13, 2026Contributor·

  ·
  2

• Return rows of unbounded Beam SQL queries while the pipeline runs

  extensionsicebergjavaNext Action: Reviewerssize/lsql
  #41315·ahmedabu98 opened Nov 13, 2026Contributor·

  ·
  7

• Check in-memory cache before queuing reads in WindmillMultimap and WindmillMap

  dataflowNext Action: Reviewersrunnerssize/m
  #41303·stankiewicz opened Nov 13, 2026Contributor·

  ·
  1

  2

• Rotate testcontainers SESSION_ID in cleanup_testcontainer_on_retry when Reaper fails

  pythonsize/stest-failure-cleanup
  #41302·damccorm opened Nov 13, 2026Contributor·

  ·
  2

• Avoid byte-offset splitting and truncation on compressed files in Go textio

  coregoioready-for-humansize/stest-failure-cleanup
  #41301·damccorm opened Nov 13, 2026Contributor·

  ·
  2

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

  size/xlwebsite
  #41300·jrmccluskey opened Nov 13, 2026Contributor·

  ·
  1

• Clear idsAvailableValue when idsAvailable becomes empty in IdTracker

  dataflowNext Action: Reviewersrunnerssize/s
  #41298·stankiewicz opened Nov 13, 2026Contributor·

  ·
  2