Kezdőlap Felfedezés Súgó
Bejelentkezés
RONCC
/
Big-Data-HPC-Platform
Figyelés 1
Kedvenc 0
Másolás 0
Fájlok Problémák 0 Beolvasztási kérések 0 Wiki
Forráskód Böngészése

HPCC-10688 EclWatch misreporting partially suspended queries

Queries that are suspended on some roxie nodes but not others where not
always reported as suspended.  Make control:queries check all nodes.

Also if some nodes are suspended and others are not, indicate that
fact on EclWatch so that users are more aware that results and apparent
availability can be affected.

Signed-off-by: Anthony Fishbeck <anthony.fishbeck@lexisnexis.com>
Tony 11 éve
szülő
1afb30d03d
commit
a6e89832c0
4 módosított fájl, 17 hozzáadás és 5 törlés
Osztott Nézet Diff Statisztika Mutatása
  1. 1 1
      esp/eclwatch/ws_XSLT/WUQueryDetails.xslt
  2. 6 2
      esp/eclwatch/ws_XSLT/WUQuerysetQueries.xslt
  3. 2 1
      esp/scm/ws_workunits.ecm
  4. 8 1
      esp/services/ws_workunits/ws_workunitsQuerySets.cpp

+ 1 - 1
esp/eclwatch/ws_XSLT/WUQueryDetails.xslt
Fájl Megtekintése 

@@ -148,7 +148,7 @@
 
             <body class="yui-skin-sam">
 
                 <xsl:variable name="suspendedOnClusters">
 
                     <xsl:for-each select="Clusters/ClusterQueryState[State='Suspended']">
 
-                        <xsl:if test="position() > 1"><xsl:text>, </xsl:text></xsl:if><xsl:value-of select="Cluster"/>
 
+                        <xsl:if test="position() > 1"><xsl:text>, </xsl:text></xsl:if><xsl:value-of select="Cluster"/><xsl:if test="MixedNodeStates=1"><xsl:text>(some nodes)</xsl:text></xsl:if>
 
                     </xsl:for-each>
 
                 </xsl:variable>
 
                 <h3>Query Details for <xsl:value-of select="QueryId"/></h3>

+ 6 - 2
esp/eclwatch/ws_XSLT/WUQuerysetQueries.xslt
Fájl Megtekintése 

@@ -444,12 +444,16 @@
 
                   <xsl:for-each select="Clusters/ClusterQueryState[State='Suspended']">
 
                       <xsl:choose>
 
                           <xsl:when test="position() = 1">
 
-                              <xsl:text>On Cluster(s): </xsl:text><xsl:value-of select="Cluster"/>
 
+                              <xsl:text>On Cluster(s): </xsl:text>
 
                           </xsl:when>
 
                           <xsl:otherwise>
 
-                              <xsl:text>, </xsl:text><xsl:value-of select="Cluster"/>
 
+                              <xsl:text>, </xsl:text>
 
                           </xsl:otherwise>
 
                       </xsl:choose>
 
+                      <xsl:value-of select="Cluster"/>
 
+                      <xsl:if test="MixedNodeStates=1">
 
+                        <xsl:text>(some nodes)</xsl:text>
 
+                      </xsl:if>
 
                   </xsl:for-each>
 
               </xsl:otherwise>
 
           </xsl:choose>

+ 2 - 1
esp/scm/ws_workunits.ecm
Fájl Megtekintése 

@@ -1168,6 +1168,7 @@ ESPStruct ClusterQueryState
 
     string Cluster;
 
     string State;
 
     [min_ver("1.46")] string Errors;
 
+    [min_ver("1.47")] bool MixedNodeStates;
 
 };
 
 
 ESPStruct [nil_remove] QuerySetQuery
 
@@ -1443,7 +1444,7 @@ ESPresponse [exceptions_inline] WUCreateZAPInfoResponse
 
 };
 
 
 ESPservice [
 
-    version("1.46"), default_client_version("1.46"),
 
+    version("1.47"), default_client_version("1.47"),
 
     noforms,exceptions_inline("./smc_xslt/exceptions.xslt"),use_method_name] WsWorkunits
 
 {
 
     ESPmethod [resp_xsl_default("/esp/xslt/workunits.xslt")]     WUQuery(WUQueryRequest, WUQueryResponse);

+ 8 - 1
esp/services/ws_workunits/ws_workunitsQuerySets.cpp
Fájl Megtekintése 

@@ -613,12 +613,15 @@ void addClusterQueryStates(IPropertyTree* queriesOnCluster, const char *target,
 
     Owned<IPropertyTreeIterator> iter = queriesOnCluster->getElements(xpath.str());
 
     bool found = false;
 
     bool suspended = false;
 
+    bool available = false;
 
     StringBuffer errors;
 
     ForEach (*iter)
 
     {
 
         found = true;
 
         if (iter->query().getPropBool("@suspended", false))
 
             suspended = true;
 
+        else
 
+            available = true;
 
         const char* error = iter->query().queryProp("@error");
 
         if (error && *error && (version >=1.46))
 
         {
 
@@ -630,7 +633,11 @@ void addClusterQueryStates(IPropertyTree* queriesOnCluster, const char *target,
 
     if (!found)
 
         clusterState->setState("Not Found");
 
     else if (suspended)
 
+    {
 
         clusterState->setState("Suspended");
 
+        if (available)
 
+            clusterState->setMixedNodeStates(true);
 
+    }
 
     else
 
         clusterState->setState("Available");
 
     if ((version >=1.46) && errors.length())
 
@@ -831,7 +838,7 @@ IPropertyTree* getQueriesOnCluster(const char *target, const char *queryset)
 
     try
 
     {
 
         Owned<ISocket> sock = ISocket::connect_timeout(eps.item(0), ROXIECONNECTIONTIMEOUT);
 
-        return sendRoxieControlQuery(sock, "<control:queries/>", ROXIECONTROLQUERYTIMEOUT);
 
+        return sendRoxieControlAllNodes(sock, "<control:queries/>", true, ROXIECONTROLQUERYTIMEOUT);
 
     }
 
     catch(IException* e)
 
     {