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-564. HAWQ-564. Resume resource dispatching when reset a RUAlive pending segment
Date Tue, 05 Apr 2016 01:23:04 GMT
Repository: incubator-hawq
Updated Branches:
  refs/heads/master b7a8528ce -> 3828d9147


HAWQ-564. HAWQ-564. Resume resource dispatching when reset a RUAlive pending segment


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

Branch: refs/heads/master
Commit: 3828d9147f6175848fb239f610c6b2cd2e6b8c8c
Parents: b7a8528
Author: YI JIN <yjin@pivotal.io>
Authored: Tue Apr 5 11:22:44 2016 +1000
Committer: YI JIN <yjin@pivotal.io>
Committed: Tue Apr 5 11:22:44 2016 +1000

----------------------------------------------------------------------
 src/backend/resourcemanager/communication/rmcomm_RM2RMSEG.c | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-hawq/blob/3828d914/src/backend/resourcemanager/communication/rmcomm_RM2RMSEG.c
----------------------------------------------------------------------
diff --git a/src/backend/resourcemanager/communication/rmcomm_RM2RMSEG.c b/src/backend/resourcemanager/communication/rmcomm_RM2RMSEG.c
index c784f65..50038b1 100644
--- a/src/backend/resourcemanager/communication/rmcomm_RM2RMSEG.c
+++ b/src/backend/resourcemanager/communication/rmcomm_RM2RMSEG.c
@@ -210,12 +210,18 @@ void receivedRUAliveResponse(AsyncCommMessageHandlerContext  context,
 			refreshActualMinGRMContainerPerSeg();
 		}
 		else {
-			elog(DEBUG3, "Resource manager find host %s is down already.",
+			elog(DEBUG3, "Resource manager finds host %s is down already.",
 						 GET_SEGRESOURCE_HOSTNAME(segres));
 		}
 	}
+	else
+	{
+		elog(DEBUG3, "Resource manager finds host %s still up.");
+	}
 
 	setSegResRUAlivePending(segres, false);
+	PQUEMGR->toRunQueryDispatch = true;
+
 	closeFileDesc(context->AsyncBuffer);
 }
 


Mime
View raw message