All pull requests

Pull requests

• fix flakey python tests - part 1

  pythonyaml
  #40228·derrickaw opened Sep 22, 2026·

  ·

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

  website
  #40227·Amar3tto opened Sep 22, 2026·

  ·
  1

• [Python] Support Lakehouse runtime catalog tables in ReadFromBigQuery…

  gcpiopython
  #40225·claudevdm opened Sep 22, 2026·

  ·

• Adds support to UngroupedWindmillReader for empty element metadata.

  dataflowNext Action: Reviewersrunners
  #40224·acrites opened Sep 22, 2026·

  ·
  2

• Address wrap-up items for Iceberg side input table cache

  icebergiojavaNext Action: Reviewers
  #40222·jrmccluskey opened Sep 22, 2026·

  ·
  1

  6

• [Python] Add reusable decision model primitives

  examplespython
  #40220·bvolpato opened Sep 22, 2026·

  ·

• [Spanner Change Streams] Claim last processed timestamp instead of query end timestamp for unbounded queries

  gcpiojavaNext Action: Reviewersspanner
  #40209·jiangzzhu opened Sep 21, 2026·

  ·
  7

• update BigTable to Bigtable for non-yaml related files

  bigtablebuildcoreexamplesextensionsgcpinfraiojavalearningNext Action: Reviewerspythonsqlwebsite
  #40207·derrickaw opened Sep 21, 2026·

  ·
  7

• Return last evaluated progress on lock timeout in RestrictionTrackers.getProgress

  corejava
  #40205·damccorm opened Sep 21, 2026·

  ·
  12

• [Java][BigQueryIO] Honor allowMissingRequiredFields when building Storage Write API messages

  gcpiojavaNext Action: Reviewers
  #40204·khaledh opened Sep 21, 2026·

  ·
  1

  1

• [Java][BigQueryIO] Use schema ordinals as verified hints for TableRow descriptor lookup

  gcpiojavaNext Action: Reviewers
  #40203·khaledh opened Sep 21, 2026·

  ·
  1

  1

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

  website
  #40198·Amar3tto opened Sep 21, 2026·

  ·
  1

• Add OpenTelemetry tracing support to SolaceIO

  buildiojavaNext Action: Reviewers
  #40187·singhmrinal02 opened Sep 20, 2026·

  ·
  7

• [KafkaIO] Add with_gcp_adc and num_partitions options to Kafka SchemaTransforms and YAML

  iojavakafkaNext Action: Reviewerspythonyaml
  #40181·Abacn opened Sep 18, 2026·

  ·
  6

• Remove upper bound pin for cryptography.

  Next Action: Reviewerspython
  #40180·aebrahim opened Sep 18, 2026·

  ·
  1

• normalize BigQuery CDC

  Next Action: Reviewerspythonyaml
  #40177·aIbrahiim opened Sep 18, 2026·

  ·
  3

• [KafkaIO] Advance idle partition watermark without requiring a record

  iojavakafkaNext Action: Reviewers
  #40176·udayaw opened Sep 18, 2026·

  ·
  6

• AddFiles: Add dry_run

  icebergiojavaNext Action: Reviewerspythonyaml
  #40167·claudevdm opened Sep 18, 2026·

  ·
  15

• [Go SDK] PostgreSQLIO core configuration, write sinks, and auth providers

  goioNext Action: Reviewers
  #40166·jk-shah opened Sep 18, 2026·

  ·
  2

• [Python] Honor disableCounterMetrics, disableStringSetMetrics and disableBoundedTrieMetrics experiments

  coreNext Action: Reviewerspythonrunners
  #40165·anishmehta24 opened Sep 17, 2026·

  ·
  1

  5

• Fix JaCoCo coverage for multiple test tasks.

  buildNext Action: Reviewers
  #40164·singhmrinal02 opened Sep 17, 2026·

  ·
  2

• [Iceberg CDC sink] Top API layer

  icebergiojavaNext Action: Reviewers
  #40161·ahmedabu98 opened Sep 17, 2026·

  ·
  23

• [Go SDK] Add portable logical type registration and standard date and micros_instant types

  coregoNext Action: Reviewers
  #40154·Eliaaazzz opened Sep 17, 2026·

  ·
  1

• [Go SDK] Convert logical type arguments to and from schema protos

  coregoNext Action: Reviewers
  #40153·Eliaaazzz opened Sep 17, 2026·

  ·
  2

• [Go SDK] Encode INT16 row fields as big endian to match Java and Python

  coregoNext Action: Reviewers
  #40152·Eliaaazzz opened Sep 17, 2026·

  ·
  1

  4