(storm) branch master updated: [STORM-4022] Do not log Exception when getting heartbeat timeout for dead topologies

[jn...@apache.org]

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 <bi...@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);