This is an automated email from the ASF dual-hosted git repository. dlych pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit fa87658b139e3941c79f98a7e5cd17c1c66a74cd Author: Michael Blow <[email protected]> AuthorDate: Thu Apr 8 09:25:28 2021 -0400 [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 <[email protected]> Tested-by: Jenkins <[email protected]> Reviewed-by: Michael Blow <[email protected]> Reviewed-by: Till Westmann --- .../src/main/java/org/apache/asterix/active/ActiveManager.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveManager.java b/asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveManager.java index 08e1be4..26b5068 100644 --- a/asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveManager.java +++ b/asterixdb/asterix-active/src/main/java/org/apache/asterix/active/ActiveManager.java @@ -140,7 +140,8 @@ public class ActiveManager { 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 @@ public class ActiveManager { 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);
