All pull requests

Pull requests

• feat(aqe): coalesce shuffle partitions down to a single partition

  documentation
  #2782·andygrove opened Nov 5, 2026Member·

  ·
  1

• fix: stop the shuffle write of a cancelled task

  #2780·0xdeafbeef opened Nov 5, 2026·

  ·

• Bound the executor pool's shared connections

  #2779·goingforstudying-ctrl opened Nov 5, 2026Contributor·

  ·
  1

• ci: label pull requests from workflow_run instead of pull_request_target

  development-process
  #2778·codekongdev opened Nov 5, 2026·

  ·
  1

• fix(executor): keep private workdirs alive until shuffle writers quiesce

  #2775·aetherxeg-source opened Nov 4, 2026·

  ·
  1

  1

• perf(core): split sort-shuffle rows by partition on arrival when it fits

  documentation
  #2774·NoahKusaba opened Nov 4, 2026Contributor·

  ·
  1

• feat: run a repeated subplan's stage once under AQE

  documentation
  #2765·andygrove opened Nov 3, 2026Member·

  ·
  1

  29

• fix(aqe): explain incompatible skew-join settings

  #2764·wirybeaver opened Nov 3, 2026Contributor·

  ·

• chore: comet-native integration branch (testing with Comet native executors)

  documentation
  #2755·andygrove opened Nov 3, 2026Member·

  ·

• feat(python): Add Python gRPC client with BallistaPythonSessionContext

  development-processdocumentationpython
  #2754·milenkovicm opened Nov 3, 2026Contributor·

  ·
  10

• fix(scheduler): free intermediate shuffle files when an adaptive job succeeds

  #2753·PDGGK opened Nov 3, 2026·

  ·
  1

• feat: add zero-wait distributed runtime filtering to AQE

  documentation
  #2749·wirybeaver opened Nov 2, 2026Contributor·

  ·
  2

• feat(python): python project cleanup and s3 support for python cluster

  documentationpython
  #2748·milenkovicm opened Nov 2, 2026Contributor·

  ·
  1

  20

• feat(scheduler): rebuild and resume a query that loses DataFrame::cache() data

  documentation
  #2730·akshaychitneni opened Nov 1, 2026Contributor·

  ·
  1

• feat: let hash shuffles place rows by a client-computed partition id

  documentation
  #2723·andygrove opened Oct 31, 2026Member·

  ·
  1

  1

• fix: plan a range RepartitionExec as a shuffle stage instead of dropping it

  api-changedocumentation
  #2722·andygrove opened Oct 31, 2026Member·

  ·
  1

• feat: let custom ExecutionPlan nodes restrict themselves to a task's partitions

  api-changedocumentation
  #2721·andygrove opened Oct 31, 2026Member·

  ·
  1

  7

• chore: pin DataFusion to a commit on branch-56 ahead of DataFusion 56

  api-changepython
  #2718·andygrove opened Oct 30, 2026Member·

  ·
  3

• fix(executor): bound each scheduler connect attempt by the connect deadline

  #2715·samuel7james opened Oct 30, 2026Contributor·

  ·
  3

• fix(scheduler): reset unlaunched tasks when executor metadata is missing

  #2698·ump45nose opened Oct 29, 2026Contributor·

  ·
  1

  1

• feat: expose provider-owned bucket scan layouts

  development-processdocumentation
  #2694·wirybeaver opened Oct 29, 2026Contributor·

  ·

• ci: run the TPC-DS and TPC-H suites under both the static and adaptive planners

  development-process
  #2649·andygrove opened Oct 26, 2026Member·

  ·
  3

• feat(iceberg): scan Iceberg tables in Ballista

  development-processdocumentation
  #2638·NoahKusaba opened Oct 21, 2026Contributor·

  ·
  27

• [DO NOT MERGE] test(executor): exercise DataFusion StageBoundary API

  #2592·edmondop opened Oct 14, 2026·

  ·

• fix(scheduler): read a swapped broadcast partitioned on the probe side

  #2501·NoahKusaba opened Sep 28, 2026Contributor·

  ·
  1

  12