hawq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From y...@apache.org
Subject incubator-hawq git commit: HAWQ-640. Wrongly timing the reqeusts for YARN containers causes resource manager not fully acquire resource
Date Sat, 09 Apr 2016 01:07:02 GMT
Repository: incubator-hawq
Updated Branches:
  refs/heads/master 0ee50a91b -> a1872589e


HAWQ-640. Wrongly timing the reqeusts for YARN containers causes resource manager not fully
acquire resource


Project: http://git-wip-us.apache.org/repos/asf/incubator-hawq/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-hawq/commit/a1872589
Tree: http://git-wip-us.apache.org/repos/asf/incubator-hawq/tree/a1872589
Diff: http://git-wip-us.apache.org/repos/asf/incubator-hawq/diff/a1872589

Branch: refs/heads/master
Commit: a1872589eb96ff5cb9e978280b7a01aeb6d302cc
Parents: 0ee50a9
Author: YI JIN <yjin@pivotal.io>
Authored: Sat Apr 9 11:06:47 2016 +1000
Committer: YI JIN <yjin@pivotal.io>
Committed: Sat Apr 9 11:06:47 2016 +1000

----------------------------------------------------------------------
 src/backend/resourcemanager/resourcemanager.c | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/a1872589/src/backend/resourcemanager/resourcemanager.c
----------------------------------------------------------------------
diff --git a/src/backend/resourcemanager/resourcemanager.c b/src/backend/resourcemanager/resourcemanager.c
index 9732df8..f460ba5 100644
--- a/src/backend/resourcemanager/resourcemanager.c
+++ b/src/backend/resourcemanager/resourcemanager.c
@@ -2194,7 +2194,6 @@ int generateAllocRequestToBroker(void)
 	/* Call resource broker to request resource. */
 	if ( reqmem > 0 && reqcore > 0 )
 	{
-
 		/*
 		 * Here we know that we have to allocate more resource from GRM, we should
 		 * check again to enrich the preferred host list for new locality data
@@ -2211,6 +2210,8 @@ int generateAllocRequestToBroker(void)
 
 		if ( reqcore > 0 )
 		{
+			PRESPOOL->LastResAcqTime = gettime_microsec();
+
 			addResourceBundleData(&(mctrack->TotalPending), reqmem, reqcore);
 			uint64_t oldtime = mctrack->TotalPendingStartTime;
 			if ( mctrack->TotalPendingStartTime == 0 )
@@ -2906,7 +2907,6 @@ void generateResourceRequestToResourceBroker(void)
 
 	if ( !isCleanGRMResourceStatus() )
 	{
-
 		curtime = gettime_microsec();
 
         if ( PRESPOOL->Segments.NodeCount > 0 && PQUEMGR->RatioCount >
0 )
@@ -2914,7 +2914,6 @@ void generateResourceRequestToResourceBroker(void)
         	refreshMemoryCoreRatioLevelUsage(curtime);
         	if ( curtime - PRESPOOL->LastResAcqTime > 1000000LL)
         	{
-        		PRESPOOL->LastResAcqTime = curtime;
 				res = generateAllocRequestToBroker();
 				if ( res != FUNC_RETURN_OK )
 				{


Mime
View raw message