All pull requests

Pull requests

• Retry transient errors in BigqueryClient.queryUnflattened

  gcpiojavaNext Action: Reviewerssize/m
  #40793·mxtymoshyk opened Oct 25, 2026Contributor·

  ·
  1

  1

• Optimize Row construction, RowWithGetters field caching, and Row utilities

  corejavasize/xl
  #40791·sjvanrossum opened Oct 25, 2026Contributor·

  ·
  1

• [Java] BigQueryIO: support integer-range partitioning in Write

  dataflowgcpiojavaNext Action: Reviewersrunnerssize/xl
  #40790·mxtymoshyk opened Oct 25, 2026Contributor·

  ·
  1

  7

• Fix Row equality/hashing, RowUtils validation and ByteBuffer handling, and LogicalTypeCoder DATETIME conversion

  corejavasize/m
  #40789·sjvanrossum opened Oct 25, 2026Contributor·

  ·
  1

• Prevent Fn data plane deadlock via non-blocking CancellableQueue.add and gRPC inbound flow control

  corejavaNext Action: Reviewerssize/l
  #40788·sjvanrossum opened Oct 25, 2026Contributor·

  ·
  12

• [Spark] Resolve the structured streaming pipeline state from the execution, cancel() returns the observed state

  runnerssize/mspark
  #40787·tkaymak opened Oct 25, 2026Contributor·

  ·
  1

  2

• [DebeziumIO] Enable Transaction Metadata Events in DebeziumIO JSON Output

  iojavaNext Action: Authorsize/m
  #40785·ilyasahsan123 opened Oct 25, 2026Contributor·

  ·
  4

• [InfluxDB] Wait for HTTP readiness before integration tests

  buildsize/s
  #40783·bvolpato opened Oct 25, 2026Contributor·

  ·

• [SingleStore] Wait for endpoint reachability

  buildinfrasize/s
  #40782·bvolpato opened Oct 25, 2026Contributor·

  ·

• [Iceberg] Make streaming metadata assertions deterministic

  icebergiojavaNext Action: Reviewerssize/s
  #40781·bvolpato opened Oct 25, 2026Contributor·

  ·
  2

• [Go] Avoid integration job name collisions

  gosize/s
  #40780·bvolpato opened Oct 25, 2026Contributor·

  ·

• [Python] Fix Hugging Face API error and token handling

  pythonsize/s
  #40779·bvolpato opened Oct 25, 2026Contributor·

  ·
  1

• Update beam-site PR on release candidate reruns

  buildsize/xs
  #40778·bvolpato opened Oct 25, 2026Contributor·

  ·

• [CI] Fix Go dependency cache path

  size/xs
  #40777·bvolpato opened Oct 25, 2026Contributor·

  ·

• [Python] Make remote inference retry tests deterministic

  pythonsize/s
  #40776·bvolpato opened Oct 25, 2026Contributor·

  ·
  1

• [Python] Preserve data channel failure causes

  Next Action: Reviewerspythonrunnerssize/s
  #40775·bgeng777 opened Oct 25, 2026·

  ·
  1

  1

• [Prism] Wait for the job service before starting loopback workers

  Next Action: Reviewersprismrunnerssize/m
  #40773·bvolpato opened Oct 25, 2026Contributor·

  ·
  2

• [Java] Avoid duplicate timestamps in InfluxDB fixtures

  iojavaNext Action: Reviewerssize/s
  #40772·bvolpato opened Oct 25, 2026Contributor·

  ·
  1

• [Python] Restore legacy TensorFlow dependency tests

  Next Action: Reviewerspythonsize/s
  #40771·bvolpato opened Oct 25, 2026Contributor·

  ·
  2

• Reduce string conversions and allocations in RowJsonDeserializer and RowJsonSerializer

  corejavasize/l
  #40770·sjvanrossum opened Oct 24, 2026Contributor·

  ·
  6

• Fix correctness issue in JsonToRow, RowJsonDeserializer and RowJsonSerializer

  corejavaNext Action: Reviewerssize/s
  #40769·sjvanrossum opened Oct 24, 2026Contributor·

  ·
  3

• Support pandas 3+ in the dataframes API (#40709)

  coreNext Action: Reviewerspythonsize/m
  #40768·dhanusharer opened Oct 24, 2026·

  ·
  1

  2

• [#36841] Spark 4 streaming: Impulse, bounded reads and PAssert on the Structured Streaming runner

  runnerssize/lspark
  #40766·tkaymak opened Oct 24, 2026Contributor·

  ·
  2

• [RunInference] Fix WatchFilePattern selecting the newest model

  examplesNext Action: Reviewerspythonsize/m
  #40765·AmoghAtreya opened Oct 24, 2026·5 tasks done·

  ·
  1

  1

• Correct typo in the staged path.

  pythonsize/xswebsite
  #40761·tvalentyn opened Oct 23, 2026Contributor·

  ·
  6