You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@quickstep.apache.org by ji...@apache.org on 2017/02/21 03:38:27 UTC
[44/50] [abbrv] incubator-quickstep git commit: Checked the query
completion upon each rebuild message in the distributed version.
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(