All pull requests

Pull requests

• Reduce Gradle build and test log spam in Java CI workflows

  builddirectiojavarunners
  #40458·Abacn opened Oct 7, 2026Contributor·3 tasks·

  ·

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

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

  ·
  3

• Add warning for KryoCoder deserialization

  extensionsjavakryoNext Action: Reviewers
  #40456·Abacn opened Oct 7, 2026Contributor·3 tasks·

  ·
  3

  

• 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

• Make AsyncWrapperTest deterministic (#40448)

  javaNext Action: Reviewers
  #40449·tkaymak opened Oct 7, 2026Contributor·1 of 3 tasks·

  ·
  1

  4

• [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

  buildcoredeltadirectelasticsearchexamplesextensionsflinkfn-executiongcpicebergiojavajdbcjetkafkakuduparquetrabbitmqrunnerssortersparksqlxml
  #40444·mxtymoshyk opened Oct 7, 2026Contributor·

  ·
  1

• Remove usage of (leaking) shared handles, which can also accidentally release the last reference holding the model.

  Next Action: Reviewerspython
  #40441·tvalentyn opened Oct 7, 2026Contributor·

  ·
  1

  3

• Removes usages of the sentence-transformers package...

  Next Action: Reviewerspythonyaml
  #40439·chamikaramj opened Oct 6, 2026Contributor·3 tasks·

  ·
  4

• Filter classes accepted by TransformUpgrader deserialization

  corejavaNext Action: Reviewers
  #40438·chamikaramj opened Oct 6, 2026Contributor·3 tasks·

  ·
  3

• 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

  

• Add FlareDB to Beam runner docs

  Next Action: Reviewerswebsite
  #40435·ganesh-skumar opened Oct 6, 2026Contributor·3 tasks·

  ·
  4

• Flink source split strategy

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

  ·

• pass the runner clock into batch triggers

  coreNext Action: Reviewerspythonrunners
  #40429·aIbrahiim opened Oct 6, 2026Contributor·3 tasks·

  ·
  2

• 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

• [#40250] Remove support for Python 3.10

  buildcoredataflowdockerinfraNext Action: Authorpythonrunnerswebsite
  #40413·parvarh26 opened Oct 5, 2026·2 of 3 tasks·

  ·
  1

  13

• Bump net.researchgate.release from 2.8.1 to 3.2.0

  dependenciesNext Action: Reviewers
  #40409·dependabot[bot] opened Oct 5, 2026Bot·

  ·
  3

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

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

  ·
  1

  1

• [Go SDK] Return job message id from WaitForCompletion

  goNext Action: Reviewersrunners
  #40404·igor-dv opened Oct 4, 2026Contributor·

  ·
  1

  5

• [Python] Return every group from Regex.find_all with Regex.ALL

  coreNext Action: Reviewerspython
  #40399·anishmehta24 opened Oct 4, 2026Contributor·1 of 3 tasks·

  ·
  13

• add redistribute kafka io parameters

  iojavakafkapythonyaml
  #40396·derrickaw opened Oct 3, 2026Collaborator·3 tasks·

  ·
  1

  2