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; }