HAWQ-552. long latency of dispatching query resource due to wrong processing routine
Project: http://git-wip-us.apache.org/repos/asf/incubator-hawq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-hawq/commit/3ae24a30 Tree: http://git-wip-us.apache.org/repos/asf/incubator-hawq/tree/3ae24a30 Diff: http://git-wip-us.apache.org/repos/asf/incubator-hawq/diff/3ae24a30 Branch: refs/heads/HAWQ-459 Commit: 3ae24a30b644c1acb939aab77931f410e6228aaf Parents: 64663ef Author: YI JIN <[email protected]> Authored: Fri Mar 18 12:40:37 2016 +1100 Committer: YI JIN <[email protected]> Committed: Fri Mar 18 12:40:37 2016 +1100 ---------------------------------------------------------------------- src/backend/resourcemanager/resourcemanager.c | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/3ae24a30/src/backend/resourcemanager/resourcemanager.c ---------------------------------------------------------------------- diff --git a/src/backend/resourcemanager/resourcemanager.c b/src/backend/resourcemanager/resourcemanager.c index 45a669e..21bf0d1 100644 --- a/src/backend/resourcemanager/resourcemanager.c +++ b/src/backend/resourcemanager/resourcemanager.c @@ -614,11 +614,8 @@ int MainHandlerLoop(void) timeoutDeadResourceAllocation(); timeoutQueuedRequest(); - /* STEP 7. Generate output content to client connections. */ - sendResponseToClients(); - /* - * STEP 8. Check the status of all segment nodes, mark down if hasn't got + * STEP 7. Check the status of all segment nodes, mark down if hasn't got * IMAlive message for a pre-defined period. */ uint64_t curtime = gettime_microsec(); @@ -631,7 +628,7 @@ int MainHandlerLoop(void) PRESPOOL->LastCheckTime = curtime; } - /* STEP 9. Move all accepted GRM containers into resource pool. */ + /* STEP 8. Move all accepted GRM containers into resource pool. */ moveAllAcceptedGRMContainersToResPool(); /* @@ -657,7 +654,7 @@ int MainHandlerLoop(void) setForcedReturnGRMContainerCount(); } - /* STEP 10. Dispatch resource to queries and send the messages out.*/ + /* STEP 9. Dispatch resource to queries and send the messages out.*/ if ( PRESPOOL->Segments.NodeCount > 0 && PQUEMGR->RatioCount > 0 && PQUEMGR->toRunQueryDispatch && PQUEMGR->ForcedReturnGRMContainerCount == 0 && @@ -678,6 +675,9 @@ int MainHandlerLoop(void) PQUEMGR->ForcedReturnGRMContainerCount); } + /* STEP 10. Generate output content to client connections. */ + sendResponseToClients(); + /* * STEP 11. Return containers to global resource manager if there some * some idle resource.
