You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hawq.apache.org by bh...@apache.org on 2016/04/06 05:42:01 UTC
[03/12] incubator-hawq git commit: HAWQ-564. HAWQ-564. Resume
resource dispatching when reset a RUAlive pending segment
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/HAWQ-617
Commit: 3828d9147f6175848fb239f610c6b2cd2e6b8c8c
Parents: b7a8528
Author: YI JIN <yj...@pivotal.io>
Authored: Tue Apr 5 11:22:44 2016 +1000
Committer: YI JIN <yj...@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);
}