Skip to content
Permalink

Comparing changes

Choose two branches to see what’s changed or to start a new pull request. If you need to, you can also or learn more about diff comparisons.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also . Learn more about diff comparisons here.
base repository: feldera/feldera
Failed to load repositories. Confirm that selected base ref is valid, then try again.
Loading
base: main
Choose a base ref
...
head repository: feldera/feldera
Failed to load repositories. Confirm that selected head ref is valid, then try again.
Loading
compare: delta-parse-spawn-blocking
Choose a head ref
Checking mergeability… Don’t worry, you can still create the pull request.
  • 1 commit
  • 1 file changed
  • 2 contributors

Commits on Aug 14, 2026

  1. adapters: run Delta parser jobs on tokio's blocking pool 

    parse_record_batch and eval_delete_filter were declared async but never
awaited anything: eval_delete_filter's body is a synchronous PhysicalExpr
evaluation, and parse_record_batch's ArrowStream::insert/delete calls are
plain sync fns. Once polled, the JobQueue worker task ran the whole
Arrow-batch-to-internal-row conversion to completion on a shared reactor
thread with no yield point, so a large batch could monopolize that thread
and delay unrelated async work (e.g. polling the network stream) queued
on it. Drop the fake async and move the parse+stage step into
spawn_blocking so it runs on tokio's dedicated blocking pool instead.

Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com>
    @blp @claude
    blp and claude committed Aug 14, 2026
    Configuration menu
    Copy the full SHA
    5b96772 View commit details
    Browse the repository at this point in the history
Loading