All pull requests

Pull requests

• Update go version to 1.26.10

  buildgoNext Action: Reviewerssize/s
  #41187·schizophrenicmaniac opened Nov 11, 2026Contributor·1 of 3 tasks·

  ·
  1

  3

• [YAML] Add error_handling to ReadFromCsv and ReadFromJson

  Next Action: Reviewerspythonsize/myaml
  #41186·codewarnab opened Nov 11, 2026·2 of 3 tasks·

  ·
  1

  14

• Fix forward references that do not resolve to types

  coreNext Action: Reviewerspythonsize/s
  #41184·jrmccluskey opened Nov 10, 2026Contributor·

  ·

  · 2.78.0 Release
  2

• Resolve zip slip + fix leaking file handles

  coregoNext Action: Reviewerssize/m
  #41183·jrmccluskey opened Nov 10, 2026Contributor·

  ·
  2

• [Prism] Schedule stateful stages with pending data before advancing T…

  goNext Action: Reviewersprismrunnerssize/m
  #41182·prodriguezdefino opened Nov 10, 2026Contributor·

  ·
  2

• Update ML Orchestration TFX Example

  examplesNext Action: Reviewerspythonsize/s
  #41181·jrmccluskey opened Nov 10, 2026Contributor·

  ·
  2

• BOM workflow update - move cadence check earlier

  buildNext Action: Reviewerssize/s
  #41179·derrickaw opened Nov 10, 2026Collaborator·

  ·
  2

• Upgrade GCP Libraries BOM to 26.93.0

  dependenciesNext Action: Reviewers
  #41178·github-actions[bot] opened Nov 10, 2026Bot·

  ·
  2

• [WIP] Implement Types for Iceberg Table Maintenance

  icebergiojavasize/xl
  #41177·jrmccluskey opened Nov 10, 2026Contributor·

  ·

• [Python] Avoid full table copy and fix size decrement in PGBKOperation.flush

  performancepythonready-for-humanrunnerssize/s
  #41176·damccorm opened Nov 10, 2026Contributor·

  ·
  6

• [Python] Avoid duplicate unpickling in DoOperation and optimize StateSampler, ShortIdCache, and OpCounters

  performancepythonready-for-humanrunnerssize/s
  #41174·damccorm opened Nov 10, 2026Contributor·

  ·
  2

• [Python] Optimize DataInputOperation.process_encoded and cache coders in FnApiUserStateContext

  performancepythonready-for-humanrunnerssize/s
  #41173·damccorm opened Nov 10, 2026Contributor·

  ·
  2

• [#36841] Website: Spark 4 Structured Streaming runner supports streaming

  size/xswebsite
  #41168·tkaymak opened Nov 10, 2026Contributor·

  ·
  3

• Skip docker pull when image is local and retry docker run on timeout in DockerCommand

  corefn-executionready-for-humanrunnerssize/stest-failure-cleanup
  #41167·damccorm opened Nov 10, 2026Contributor·

  ·
  8

• Assert at-least-once record count for STREAMING_INSERTS in BigQueryIOIT

  gcpiojavaready-for-humansize/stest-failure-cleanup
  #41166·damccorm opened Nov 10, 2026Contributor·

  ·
  2

• [YAML] Fix Join wildcard fields, empty equalities check, and test spe…

  Next Action: Authorpythonsize/syaml
  #41165·LibenHailu opened Nov 10, 2026·

  ·
  1

  3

• Avoid dropping record in _TruncatingFileHandle when restriction stop aligns with first record boundary

  pythonready-for-humansize/stest-failure-cleanup
  #41163·damccorm opened Nov 10, 2026Contributor·

  ·
  2

• [Python] Optimize _OutputHandler.handle_process_outputs and handle_process_batch_outputs

  performancepythonready-for-humanrunnerssize/s
  #41162·damccorm opened Nov 10, 2026Contributor·

  ·
  6

• [Python] Avoid empty kwargs dict allocation and unpacking in PerWindowInvoker

  Next Action: Reviewersperformancepythonrunnerssize/s
  #41161·damccorm opened Nov 10, 2026Contributor·

  ·
  5

• [Python] Canonicalize _DoFnParam placeholders and use identity checks in PerWindowInvoker

  performancepythonready-for-humanrunnerssize/s
  #41160·damccorm opened Nov 10, 2026Contributor·

  ·
  16

• [Flink] Group partial combines by the structural value of the key

  flinkrunnerssize/m
  #41158·pkuzmickas opened Nov 10, 2026Contributor·1 of 3 tasks·

  ·

• [Flink] Spread start channels of consecutive senders in batch Reshuffle

  flinkrunnerssize/m
  #41156·pkuzmickas opened Nov 10, 2026Contributor·

  ·

• Check cancelFlag when PipelineResult.waitUntilFinish throws RuntimeException in BeamEnumerableConverter

  extensionsjavaready-for-humansize/xssqltest-failure-cleanup
  #41155·damccorm opened Nov 10, 2026Contributor·

  ·
  6

• [Python] Default WriteToJson double_precision to 15 to avoid silently rounding floats

  ioNext Action: Reviewerspythonsize/s
  #41154·Abhi2939 opened Nov 10, 2026·

  ·
  1

  10

• Check holdTimestamp on overwritten event-time timers in Prism

  goprismready-for-humanrunnerssize/stest-failure-cleanup
  #41146·damccorm opened Nov 10, 2026Contributor·

  ·
  4