Skip to content
Permalink
Browse files
[NO ISSUE][*DB][EXT] Log on active stats response
Change-Id: I7dc2c552376133edc077e3584c73a6d2c9e01153
Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/10963
Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Reviewed-by: Michael Blow <mblow@apache.org>
Reviewed-by: Till Westmann
  • Loading branch information
mblow committed Apr 8, 2021
1 parent bcd7196 commit fa87658b139e3941c79f98a7e5cd17c1c66a74cd
Showing 1 changed file with 3 additions and 1 deletion.
@@ -140,7 +140,8 @@ private void requestStats(ActiveStatsRequestMessage message) throws HyracksDataE
IActiveRuntime runtime = runtimes.get(runtimeId);
long reqId = message.getReqId();
if (runtime == null) {
LOGGER.warn("Request stats of a runtime that is not registered " + runtimeId);
LOGGER.warn("Request stats of a runtime that is not registered {}; sending failure response",
runtimeId);
// Send a failure message
((NodeControllerService) serviceCtx.getControllerService()).sendApplicationMessageToCC(
message.getCcId(),
@@ -150,6 +151,7 @@ private void requestStats(ActiveStatsRequestMessage message) throws HyracksDataE
return;
}
String stats = runtime.getStats();
LOGGER.debug("Sending stats response for {} ", runtimeId);
ActiveStatsResponse response = new ActiveStatsResponse(reqId, stats, null);
((NodeControllerService) serviceCtx.getControllerService()).sendApplicationMessageToCC(message.getCcId(),
JavaSerializationUtils.serialize(response), null);

0 comments on commit fa87658

Please sign in to comment.