This is an automated email from the ASF dual-hosted git repository. jnioche pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/master by this push: new 700c8fb3b [STORM-4022] Do not log Exception when getting heartbeat timeout for dead topologies new 0aa35b78a Merge pull request #3617 from bipinprasad/storm-4022 700c8fb3b is described below commit 700c8fb3b9714ac271e652c235851bb120fc85f8 Author: bipinprasad <bipinpra...@apache.org> AuthorDate: Tue Jan 16 16:52:24 2024 -0800 [STORM-4022] Do not log Exception when getting heartbeat timeout for dead topologies --- storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java b/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java index 04296a6d4..d30fced72 100644 --- a/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java +++ b/storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java @@ -2673,6 +2673,9 @@ public class Nimbus implements Iface, Shutdownable, DaemonCommon { try { Map<String, Object> topoConf = tryReadTopoConf(topoId, topoCache); return getTopologyHeartbeatTimeoutSecs(topoConf); + } catch (NotAliveException e) { + // no log here to avoid flooding nimbus logs + return ObjectReader.getInt(conf.get(DaemonConfig.NIMBUS_TASK_TIMEOUT_SECS)); } catch (Exception e) { // contain any exception LOG.warn("Exception when getting heartbeat timeout", e);