This is an automated email from the ASF dual-hosted git repository. rzo1 pushed a commit to branch STORM-3986 in repository https://gitbox.apache.org/repos/asf/storm.git
commit 0b897bc9bb29549de18b4264b76702cddb19e2b2 Author: Richard Zowalla <[email protected]> AuthorDate: Thu Nov 9 13:25:23 2023 +0100 STORM-3986 - Get rid of BlacklistScheduler timer [INFO] logs --- .../org/apache/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 b29981f20..2f9aca767 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 @@ public class BlacklistScheduler implements IScheduler { 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; }
