Skip to content

Commit

Permalink
more aggressive cancellation of broker parallel merge, more chill blo…
Browse files Browse the repository at this point in the history
…cking queue timeouts, and query cancellation participation (apache#16748)

* more aggressive cancellation of broker parallel merge, more chill blocking queue timeouts

* wire parallel merge into query cancellation system

* oops

* style

* adjust metrics initialization

* fix timeout, fix cleanup to not block

* javadocs to clarify why cancellation future and gizmo are split

* cancelled -> canceled, simplify QueuePusher since it always takes a ResultBatch, non-static terminal marker to make stuff stop complaining about types, specialize tryOffer to be tryOfferTerminal so it wont be misused, add comments to clarify reason for non-blocking offers that might fail
  • Loading branch information
clintropolis authored and sreemanamala committed Aug 6, 2024
1 parent 5c65edd commit 49ad775
Show file tree
Hide file tree
Showing 3 changed files with 343 additions and 107 deletions.
Loading

0 comments on commit 49ad775

Please sign in to comment.