Repository: apex-core Updated Branches: refs/heads/master c42f26e01 -> 04a352b3e
APEXCORE-680 setting appropriate log level for heartbeat timeout Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/9d2707a2 Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/9d2707a2 Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/9d2707a2 Branch: refs/heads/master Commit: 9d2707a263a6a4c7247f08a423a9e2ba6b33a8da Parents: 16d1bf6 Author: Hitesh-Scorpio <[email protected]> Authored: Fri Mar 24 11:06:00 2017 +0530 Committer: Hitesh-Scorpio <[email protected]> Committed: Mon Mar 27 01:37:02 2017 +0530 ---------------------------------------------------------------------- .../com/datatorrent/stram/StreamingContainerManager.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/9d2707a2/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java b/engine/src/main/java/com/datatorrent/stram/StreamingContainerManager.java index ee07af1..a989342 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 class StreamingContainerManager implements PlanContext //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,10 +788,10 @@ public class StreamingContainerManager implements PlanContext 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); - stramEvent.setReason(info); + String msg = String.format("Container %s@%s heartbeat timeout (%d%n ms).", c.getExternalId(), c.host, currentTms - sca.lastHeartbeatMillis); + LOG.warn(msg); + StramEvent stramEvent = new StramEvent.ContainerErrorEvent(c.getExternalId(), msg, null); + stramEvent.setReason(msg); recordEventAsync(stramEvent); sca.lastHeartbeatMillis = -1; }
