Skip to content

Commit 81ac43b

Browse files
committed
STORM-3986 - Get rid of BlacklistScheduler timer [INFO] logs
1 parent fd88376 commit 81ac43b

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

storm-server/src/main/java/org/apache/storm/scheduler/blacklist/BlacklistScheduler.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -194,7 +194,11 @@ private Set<String> refreshBlacklistedSupervisorIds(Cluster cluster, Topologies
194194
new ArrayList<>(badSupervisorsToleranceSlidingWindow),
195195
new ArrayList<>(sendAssignmentFailureCount),
196196
cluster, topologies);
197-
LOG.info("Supervisors {} are blacklisted.", blacklistedSupervisors);
197+
if (blacklistedSupervisors.isEmpty()) {
198+
LOG.debug("No Supervisors are blacklisted.");
199+
} else {
200+
LOG.info("Supervisors {} are blacklisted.", blacklistedSupervisors);
201+
}
198202
return blacklistedSupervisors;
199203
}
200204

0 commit comments

Comments
 (0)