All pull requests

Pull requests

• feat(scheduler): graceful shutdown for the scheduler's gRPC and embedded Flight-proxy server

  documentation
  #2631·villebro opened Oct 19, 2026Member·

  ·

• feat(executor): report metrics from pull-based executors

  #2621·Richard-Durkee opened Oct 18, 2026Contributor·

  ·

• fix(aqe): preserve stages when transitions fail

  #2620·SIBTAIN-ASAD opened Oct 18, 2026·

  ·
  1

• feat(python): Add Python UDF support to Ballista Python bindings

  documentationpython
  #2619·milenkovicm opened Oct 18, 2026Contributor·

  ·
  2

• refactor(scheduler): share the binding driver between bind_task_bias and bind_task_round_robin

  #2617·cestercian opened Oct 16, 2026·

  ·
  1

• fix(scheduler): keep AQE stage in the graph when a stage transition fails

  #2613·DeviousCardi opened Oct 15, 2026·

  ·
  1

• [WIP][Experimental] feat: use DataFusion's isolated_partitions option for broadcast-safe join selection

  #2612·andygrove opened Oct 14, 2026Member·

  ·

• fix: share Ballista client retry handling

  #2608·1cbyc opened Oct 14, 2026·

  ·
  1

• fix(executor): honour scheduler_connect_timeout_seconds

  #2607·samuel7james opened Oct 14, 2026·

  ·
  1

  2

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

  #2592·edmondop opened Oct 14, 2026·

  ·

• feat(python): Plug into DataFusion Python natively through a custom FFI query planner

  api-changedocumentationpython
  #2588·milenkovicm opened Oct 12, 2026Contributor·

  ·
  29

• refactor(core): drain and size the sort-shuffle buffer through BufferedBatches

  api-changedocumentation
  #2579·NoahKusaba opened Oct 10, 2026Contributor·

  ·
  13

• fix(executor): cached session runtime ignores SET s3.* changes

  #2562·goingforstudying-ctrl opened Oct 7, 2026Contributor·

  ·
  1

  11

• feat(core): run queries that mix information_schema with other tables on the cluster

  #2507·andygrove opened Sep 28, 2026Member·

  ·

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

  #2501·NoahKusaba opened Sep 28, 2026Contributor·

  ·
  1

  12

• feat: add a Python ADBC example and TPC-H runner for Flight SQL

  documentation
  #2496·andygrove opened Sep 27, 2026Member·

  ·
  1

• fix(scheduler): treat broadcast_join_threshold_rows as a fallback, not a ceiling

  #2444·andygrove opened Sep 11, 2026Member·

  ·

• feat(history): replace the timer-based rescan with a filesystem watch

  #2431·milenkovicm opened Sep 7, 2026Contributor·

  ·
  3

• feat: shuffle-affinity task distribution policy

  documentation
  #2430·NoahKusaba opened Sep 7, 2026Contributor·

  ·
  1

  3

• docs(plans): TPC-H SF1000 query plans for community review (not for merge)

  documentation
  #2419·andygrove opened Sep 3, 2026Member·

  ·
  8

• fix(core): stop forwarding BallistaConfig defaults to the scheduler

  python
  #2395·AnuragRaut08 opened Aug 29, 2026Contributor·

  ·
  1

  2

• feat(scheduler): parallel bounded ROWS-frame windows via a rank-derived halo

  #2392·avantgardnerio opened Aug 27, 2026Contributor·

  ·

• ci: run Python client tests against a cluster built from the branch

  development-processpython
  #2374·andygrove opened Aug 25, 2026Member·

  ·
  1

• feat(scheduler): adopt DataFusion's cost-based join order enumeration

  #2352·Dandandan opened Aug 20, 2026Contributor·

  ·
  1

• perf(scheduler): run one stage when the plan asks for the same stage twice

  Stale
  #2345·Dandandan opened Aug 18, 2026Contributor·

  ·
  3