From 81ac43be30f8da4c76305b2fb04504d12fb29d40 Mon Sep 17 00:00:00 2001 From: Richard Zowalla Date: Thu, 9 Nov 2023 13:25:23 +0100 Subject: [PATCH] STORM-3986 - Get rid of BlacklistScheduler timer [INFO] logs --- .../storm/scheduler/blacklist/BlacklistScheduler.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/storm-server/src/main/java/org/apache/storm/scheduler/blacklist/BlacklistScheduler.java b/storm-server/src/main/java/org/apache/storm/scheduler/blacklist/BlacklistScheduler.java index b29981f20b9..2f9aca767c6 100644 --- a/storm-server/src/main/java/org/apache/storm/scheduler/blacklist/BlacklistScheduler.java +++ b/storm-server/src/main/java/org/apache/storm/scheduler/blacklist/BlacklistScheduler.java @@ -194,7 +194,11 @@ private Set refreshBlacklistedSupervisorIds(Cluster cluster, Topologies new ArrayList<>(badSupervisorsToleranceSlidingWindow), new ArrayList<>(sendAssignmentFailureCount), cluster, topologies); - LOG.info("Supervisors {} are blacklisted.", blacklistedSupervisors); + if (blacklistedSupervisors.isEmpty()) { + LOG.debug("No Supervisors are blacklisted."); + } else { + LOG.info("Supervisors {} are blacklisted.", blacklistedSupervisors); + } return blacklistedSupervisors; }