From 9f72d98d1d36350aa00668a6f09d0798a9f6aa27 Mon Sep 17 00:00:00 2001 From: Hitesh-Scorpio Date: Fri, 24 Mar 2017 11:06:00 +0530 Subject: [PATCH] APEXCORE-662 setting appropriate log level --- .../com/datatorrent/stram/StreamingContainerManager.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java b/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java index ee07af1d63..144925d216 100644 --- a/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java +++ b/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java @@ -780,7 +780,7 @@ public void monitorHeartbeat(boolean waitForRecovery) //LOG.debug("{} {} {}", c.getExternalId(), currentTms - sca.createdMillis, this.vars.heartbeatTimeoutMillis); // container allocated but process was either not launched or is not able to phone home if (currentTms - sca.createdMillis > 2 * this.vars.heartbeatTimeoutMillis) { - LOG.error("Container {}@{} startup timeout ({} ms).", c.getExternalId(), c.host, currentTms - sca.createdMillis); + LOG.warn("Container {}@{} startup timeout ({} ms).", c.getExternalId(), c.host, currentTms - sca.createdMillis); containerStopRequests.put(c.getExternalId(), c.getExternalId()); } } else { @@ -788,9 +788,9 @@ public void monitorHeartbeat(boolean waitForRecovery) if (!isApplicationIdle()) { // Check if the heartbeat for this agent has already been missed to raise the StramEvent only once if (sca.lastHeartbeatMillis != -1) { - String info = String.format("Container %s@%s heartbeat timeout (%d%n ms).", c.getExternalId(), c.host, currentTms - sca.lastHeartbeatMillis); - LOG.error(info); - StramEvent stramEvent = new StramEvent.ContainerErrorEvent(c.getExternalId(), info, null); + String info = String.format("Container %s@%s heartbeat timeout (%d%n ms).", c.getExternalId(), c.host, currentTms - sca.lastHeartbeatMillis); + LOG.warn(info); + StramEvent stramEvent = new StramEvent.ContainerErrorEvent(c.getExternalId(), info, null, StramEvent.LogLevel.WARN); stramEvent.setReason(info); recordEventAsync(stramEvent); sca.lastHeartbeatMillis = -1;