All pull requests

Pull requests

• Fix invalid POM for io-component

  iojava
  #40346·Abacn opened Sep 29, 2026Contributor·

  ·

• Expose desiredNumUnboundedSourceSplits for Java and Python portable pipeline

  coreiojavapython
  #40345·Abacn opened Sep 29, 2026Contributor·

  ·

• [Java] ParquetIO: resolve file records against the read schema

  iojavaparquet
  #40344·mxtymoshyk opened Sep 29, 2026Contributor·

  ·
  1

• add pubsub max_read_time_seconds parameter

  gcpiopythonrunnersyaml
  #40341·derrickaw opened Sep 29, 2026Collaborator·

  ·
  1

• [Gemini] GCP BigQuery IO Modern Client Migration

  gcpiopython
  #40340·jrmccluskey opened Sep 29, 2026Contributor·

  ·
  1

• Remove pull request template

  Next Action: Author
  #40339·kennknowles opened Sep 29, 2026Member·

  ·
  2

• [Cherrypick] [AvroIO, FileIO] Exposing evictWritersWhenFull in AvroIO (#40336)

  coreextensionsjava
  #40338·darshan-sj opened Sep 29, 2026Contributor·

  ·
  2

• Addfiles partition bounds fixes (#40252)

  icebergiojavaNext Action: Reviewers
  #40337·claudevdm opened Sep 29, 2026Collaborator·

  ·

  · 2.77.0 Release
  3

• Update managed-io.md for release 2.77.0-RC3

  website
  #40334·Amar3tto opened Sep 29, 2026Collaborator·

  ·
  1

• [Python] Fix LogElements crash on global window timestamps

  coreNext Action: Reviewerspython
  #40332·anishmehta24 opened Sep 29, 2026·

  ·
  2

• [Python] Validate FileBasedSink num_shards type

  coreiopython
  #40331·goutamadwant opened Sep 29, 2026Contributor·

  ·
  1

  2

• Draft: Make Presubmits faster

  buildcoredataflowdirectexamplesextensionsiojavaNext Action: Authorprismrunnerssortersyntheticwebsite
  #40324·reuvenlax opened Sep 29, 2026Contributor·

  ·
  1

• Make ValidatesRunner faster: Cache and reuse shared metrics pipeline execution in MetricsTest

  java
  #40322·reuvenlax opened Sep 28, 2026Contributor·

  ·
  2

• Add more GCS unit and integration tests to improve test coverage

  extensionsgcpjava
  #40319·shunping opened Sep 28, 2026Collaborator·

  ·

• [PR Bot] Select single main and backup reviewer using label priority

  #40315·damccorm opened Sep 28, 2026Contributor·

  ·
  5

• DNR! POC! Merge validates runner phase2

  buildcoredataflowjavaNext Action: Authorrunners
  #40303·reuvenlax opened Sep 27, 2026Contributor·

  ·
  4

• [Java] Reduce logging severity for state requests cancelled by the runner

  corejavaNext Action: Reviewers
  #40302·parveensania opened Sep 27, 2026Contributor·

  ·
  5

• Fix IcebergIO failing to write EnumerationType (proto enum) fields

  icebergiojavaNext Action: Reviewers
  #40300·mananmangal opened Sep 27, 2026Contributor·

  ·
  1

  1

• Fix flaky Java tests

  coreexamplesflinkgcpiojavajmsmqttNext Action: Reviewersprismrunnersspark
  #40298·reuvenlax opened Sep 27, 2026Contributor·

  ·
  11

• Fix flaky Python tests

  bigtableexamplesgcpioNext Action: Reviewerspythonyaml
  #40297·reuvenlax opened Sep 27, 2026Contributor·

  ·
  10

• [Java] Bound pending Watch results per poll

  corejavaNext Action: Reviewers
  #40294·goutamadwant opened Sep 27, 2026Contributor·

  ·
  3

• [Python] Fix ParquetIO silently corrupting data across windows in unbounded pipelines

  ioNext Action: Reviewerspython
  #40293·developer-rpai opened Sep 26, 2026·

  ·
  1

  1

• [POC] Improve ValidatesRunner performance. Phase 0

  coredataflowjavaNext Action: Reviewersrunners
  #40292·reuvenlax opened Sep 26, 2026Contributor·

  ·
  2

• Deflake JmsIOTest checkpoint and authentication tests

  iojavajmsNext Action: Reviewers
  #40291·mxtymoshyk opened Sep 25, 2026Contributor·

  ·
  2

  1

• Update list of stale bq dataset

  examplesextensionsgcpiceberginfraiojavaNext Action: Reviewerspythonsql
  #40286·Abacn opened Sep 25, 2026Contributor·

  ·
  4