Checked the query completion upon each rebuild message in the distributed version.
Project: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/commit/167ee872 Tree: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/tree/167ee872 Diff: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/diff/167ee872 Branch: refs/heads/LIP-time-decomposition Commit: 167ee872e4d3b52dcf15b014de20c66b51db0075 Parents: c40c553 Author: Zuyu Zhang <zu...@apache.org> Authored: Thu Feb 9 16:34:26 2017 -0800 Committer: Zuyu Zhang <zu...@apache.org> Committed: Thu Feb 9 16:34:26 2017 -0800 ---------------------------------------------------------------------- query_execution/PolicyEnforcerDistributed.cpp | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-quickstep/blob/167ee872/query_execution/PolicyEnforcerDistributed.cpp ---------------------------------------------------------------------- diff --git a/query_execution/PolicyEnforcerDistributed.cpp b/query_execution/PolicyEnforcerDistributed.cpp index 12d2037..8f0332d 100644 --- a/query_execution/PolicyEnforcerDistributed.cpp +++ b/query_execution/PolicyEnforcerDistributed.cpp @@ -159,6 +159,11 @@ void PolicyEnforcerDistributed::processInitiateRebuildResponseMessage(const tmb: query_manager->processInitiateRebuildResponseMessage( proto.operator_index(), num_rebuild_work_orders, shiftboss_index); shiftboss_directory_->addNumQueuedWorkOrders(shiftboss_index, num_rebuild_work_orders); + + if (query_manager->getQueryExecutionState().hasQueryExecutionFinished()) { + onQueryCompletion(query_manager); + removeQuery(query_id); + } } void PolicyEnforcerDistributed::getShiftbossIndexForAggregation(
