All pull requests

Pull requests

• [Dataflow Streaming] [Multikey] Route only finalize commits via multikey path

  dataflowrunners
  #40495·arunpandianp opened Oct 10, 2026Contributor·

  ·
  3

• [Java][BigQueryIO] Avoid reflective lookup in unknown-column collectors

  gcpiojavaNext Action: Reviewers
  #40491·khaledh opened Oct 9, 2026·

  ·
  1

  1

• [SpannerIO] Support excludeTxnFromChangeStreams and transactionTag in SpannerIO.Write

  gcpiojavaNext Action: Reviewersspanner
  #40489·darshan-sj opened Oct 9, 2026Contributor·2 tasks done·

  ·
  1

• Add mongodb_to_bigquery yaml blueprint example and e2e test

  Next Action: Reviewerspythonyaml
  #40485·derrickaw opened Oct 9, 2026Collaborator·

  ·
  2

• Add gcs_avro_to_bigtable yaml blueprint example and e2e test

  Next Action: Reviewerspythonyaml
  #40484·derrickaw opened Oct 9, 2026Collaborator·

  ·
  2

• [OpenTelemetry] Fix OpenTelemetry span kinds and add write spans in PubsubIO and KafkaIO

  gcpiojavakafkaNext Action: Reviewers
  #40483·stankiewicz opened Oct 9, 2026Contributor·

  ·
  3

• [Solace] Add OpenTelemetry distributed tracing support to SolaceIO (#40175)

  iojavaNext Action: Reviewers
  #40482·stankiewicz opened Oct 9, 2026Contributor·

  ·
  1

  2

• [YAML] Add SplunkIO write SchemaTransform and WriteToSplunk

  iojavaNext Action: Reviewerspythonyaml
  #40481·schizophrenicmaniac opened Oct 9, 2026Contributor·

  ·
  1

  2

• [SpannerIO] Add withWriteResults() to SpannerIO.Write to emit commit metadata

  gcpiojavaNext Action: Reviewersspanner
  #40480·stankiewicz opened Oct 9, 2026Contributor·

  ·
  1

• [DebeziumIO] Update Debezium documentation link to version 3.5

  iojavaNext Action: Reviewers
  #40477·ilyasahsan123 opened Oct 9, 2026·4 tasks·

  ·
  3

• Fix ModelManager tag mismatch on release after model update (#40469)

  Next Action: Reviewerspython
  #40473·AMOOOMA opened Oct 8, 2026Contributor·

  ·
  5

• Add bigquery_to_bigtable yaml blueprint example and e2e test

  Next Action: Reviewerspythonyaml
  #40472·derrickaw opened Oct 8, 2026Collaborator·

  ·
  2

• [Python] Catch PermissionDenied when checking the feature store in VertexAIFeatureStoreEnrichmentHandler

  coreNext Action: Reviewerspython
  #40463·schizophrenicmaniac opened Oct 8, 2026Contributor·2 of 3 tasks·

  ·
  1

  2

• [Iceberg CDC source] Allow dropping PK or watermark columns

  icebergiojavaNext Action: Reviewers
  #40457·ahmedabu98 opened Oct 7, 2026Contributor·3 tasks·

  ·
  4

• Propagate stable code identifier pickling and preserve pickler config

  coreNext Action: Reviewerspython
  #40453·kristynsmith opened Oct 7, 2026Contributor·3 tasks·

  ·
  3

• Export runtimeOnly dependencies to Maven POM for unshaded modules

  build
  #40450·stankiewicz opened Oct 7, 2026Contributor·

  ·
  9

• [Spark 4] Filter late data against the key's previous watermark in the streaming stateful ParDo

  runnersspark
  #40447·tkaymak opened Oct 7, 2026Contributor·

  ·
  3

• [Java] Make non-extensible classes final instead of suppressing CT_CONSTRUCTOR_THROW

  coreexamplesflinkfn-executionjavajetNext Action: Reviewersrunnersspark
  #40444·mxtymoshyk opened Oct 7, 2026Contributor·

  ·
  1

• Add PipelineOptions changes for merging ValidatesRunner tests.

  corejavaNext Action: Reviewers
  #40437·reuvenlax opened Oct 6, 2026Contributor·

  ·
  3

  

• Prep changes for merging ValidatesRunner jobs

  corejavaNext Action: Reviewers
  #40436·reuvenlax opened Oct 6, 2026Contributor·

  ·
  3

  

• Flink source split strategy

  flinkrunnerswebsite
  #40433·jto opened Oct 6, 2026Contributor·3 tasks·

  ·

• Remove whitespace for generated managed doc

  icebergiojava
  #40422·ahmedabu98 opened Oct 5, 2026Contributor·3 tasks·

  ·
  2

• [Java][BigQueryIO] Fix BigQueryIO streaming insert silently dropping transient network errors during response body read

  gcpiojavaNext Action: Reviewers
  #40420·damjad opened Oct 5, 2026Contributor·7 tasks·

  ·
  1

  3

• Handle null split initialization results in Flink lazy source enumerator

  flinkNext Action: Reviewersrunners
  #40417·ddebowczyk92 opened Oct 5, 2026Contributor·3 tasks·

  ·
  3

• [Go SDK] wrap a failed last data/timer send like Flush

  coregoNext Action: Reviewers
  #40406·igor-dv opened Oct 4, 2026Contributor·

  ·
  1

  2