mirror of
https://github.com/apache/impala.git
synced 2026-01-03 15:00:52 -05:00
7725f25ff5
- executor takes report callback; passed in by ImpalaServer::FragmentExecState - the PlanFragmentExecutor invokes profile reporting cb in background thread. - RuntimeProfile is now thread-safe and has an RuntimeProfile::Update() Also included: - a number of bug fixes related to async cancellation of query and propagation of errors through PlanFragmentExecutor/Coordinator/ImpalaServer. - changing COUNTER_SCOPED_TIMER to SCOPED_TIMER - derived counters: RuntimeProfile now lets you add counters that return a value via a function call, which is useful for reporting something like normalized ScanNode throughput; retrofitted to ScanNode and all subclasses - changed coordinator to make cancellation atomic wrt recognition of an error status for the overall query. - Removed InProcessQueryExecutor from data-stream-test. Added aggregate throughput counters to coordinator: - all throughput counters are grouped in a sub-profile "AggregateThroughput" - each scan node gets its own counter - the value is aggregated across all registered backends which contain that node in their plan fragments