All pull requests

Pull requests

• [YAML] Fix SQL-backed Combine query generation for Calcite expressions and SQL shorthand (#41288)

  Next Action: Reviewerspythonsize/myaml
  #41289·vishalmore90 opened Nov 13, 2026Contributor·

  ·
  1

  1

• Synchronize SingleEmitInputDStream batches with GlobalWatermarkHolder

  runnerssize/ssparktest-failure-cleanup
  #41286·damccorm opened Nov 13, 2026Contributor·

  ·
  1

• [Java Harness] Handle swallowed exceptions across fused DoFns

  corejavaNext Action: Reviewerssize/l
  #41285·knockknock10 opened Nov 13, 2026·

  ·
  7

• [Python] Fix DataFrame skew() and kurtosis() with a single non-empty partition

  Next Action: Reviewerspythonsize/s
  #41284·sohailshk opened Nov 13, 2026Contributor·

  ·
  1

  1

• [Python] Do not modify input elements in the embedding output functions

  Next Action: Reviewerspythonsize/m
  #41282·sohailshk opened Nov 13, 2026Contributor·

  ·
  1

  1

• Run testAfterProcessingTimeContinuationTriggerUsingState serially with 2s watermark hold

  javasize/xstest-failure-cleanup
  #41281·damccorm opened Nov 13, 2026Contributor·

  ·
  2

• Use 20-minute JUnit timeout on non-DirectRunner in DeltaLakeToIcebergCdcIT

  icebergiojavaready-for-humansize/xstest-failure-cleanup
  #41280·damccorm opened Nov 13, 2026Contributor·

  ·
  2

• [Python] Optimize DataFrame Index.partition_fn and DataFrameBatchConverter.explode_batch

  coreperformancepythonready-for-humansize/s
  #41279·damccorm opened Nov 13, 2026Contributor·

  ·
  3

• [Python] Binary search row groups in _ParquetUtils.find_first_row_group_index

  ioperformancepythonready-for-humansize/s
  #41278·damccorm opened Nov 13, 2026Contributor·

  ·
  3

• [Python] Cache unpacked side inputs in _PartialGroupByKeyCombiningValues and optimize ListBatchConverter

  coreperformancepythonready-for-humansize/s
  #41277·damccorm opened Nov 13, 2026Contributor·

  ·
  3

• [Python] Fast-path unbuffered append in ApproximateQuantilesCombineFn.add_input

  coreperformancepythonready-for-humansize/s
  #41276·damccorm opened Nov 13, 2026Contributor·

  ·
  3

• [Python] Reuse cached _TypedMetricName in MetricsContainer cell lookups

  performancepythonready-for-humansize/s
  #41275·damccorm opened Nov 13, 2026Contributor·

  ·
  8

• [Python] Hoist CompressionTypes lookup tables to class constants

  coreioperformancepythonready-for-humansize/s
  #41274·damccorm opened Nov 13, 2026Contributor·

  ·
  3

• [Python] Avoid buffer malloc in Cython ByteCountingOutputStream and use bit_length in get_varint_size

  coreperformancepythonready-for-humansize/s
  #41273·damccorm opened Nov 13, 2026Contributor·

  ·
  3

• [Python] Hoist GroupBy._key_func outside Map and optimize Partition.ApplyPartitionFnFn

  coreperformancepythonready-for-humansize/s
  #41272·damccorm opened Nov 13, 2026Contributor·

  ·
  3

• [Python] Cache __hash__, fast_name, and _TypedMetricName on MetricName

  performancepythonready-for-humansize/s
  #41271·damccorm opened Nov 13, 2026Contributor·

  ·
  9

• [Python] Precompile struct.Struct instances and avoid dynamic format strings in _TFRecordUtil

  ioperformancepythonready-for-humansize/s
  #41270·damccorm opened Nov 13, 2026Contributor·

  ·
  2

• [Python] Optimize RowCoderImpl attribute extraction and NamedTuple construction

  coreperformancepythonready-for-humansize/s
  #41269·damccorm opened Nov 13, 2026Contributor·

  ·
  2

• [Python] Cache FileSystem subclasses by scheme in FileSystems.get_filesystem

  coreioperformancepythonready-for-humansize/s
  #41268·damccorm opened Nov 13, 2026Contributor·

  ·
  5

• [Python] Avoid Timestamp allocation in WindowedValueCoderImpl.get_estimated_size_and_observables

  coreperformancepythonready-for-humansize/s
  #41267·damccorm opened Nov 13, 2026Contributor·

  ·
  2

• Bump golang.org/x/text from 0.43.0 to 0.44.0 in /sdks

  dependenciesgoNext Action: Reviewerssize/s
  #41266·dependabot[bot] opened Nov 13, 2026Bot·

  ·
  1

• Bump github.com/aws/aws-sdk-go-v2/config from 1.33.16 to 1.33.17 in /sdks

  dependenciesgosize/s
  #41265·dependabot[bot] opened Nov 13, 2026Bot·

  ·
  1

• Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager from 1.23.22 to 1.23.23 in /sdks

  dependenciesgoNext Action: Reviewerssize/s
  #41264·dependabot[bot] opened Nov 13, 2026Bot·

  ·
  1

• Bump github.com/aws/smithy-go from 1.28.8 to 1.28.9 in /sdks

  dependenciesgoNext Action: Reviewerssize/xs
  #41263·dependabot[bot] opened Nov 13, 2026Bot·

  ·
  1

• Bump github.com/aws/aws-sdk-go-v2/credentials from 1.20.16 to 1.20.17 in /sdks

  dependenciesgoNext Action: Reviewerssize/s
  #41262·dependabot[bot] opened Nov 13, 2026Bot·

  ·
  1