From 51787690d9d1315054671ff9ea8af875685811e1 Mon Sep 17 00:00:00 2001 From: Tiaan Louw Date: Wed, 10 Mar 2021 12:14:44 +0100 Subject: [PATCH] Silence warning when there are no stale streams to delete --- .../software/amazon/kinesis/coordinator/Scheduler.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java index d7523549..06429ee3 100644 --- a/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java +++ b/amazon-kinesis-client/src/main/java/software/amazon/kinesis/coordinator/Scheduler.java @@ -562,10 +562,12 @@ public class Scheduler implements Runnable { final Set staleStreamIdsToBeRevived = staleStreamIdDeletionDecisionMap.get(true); removeStreamsFromStaleStreamsList(staleStreamIdsToBeRevived); - log.warn( - "Streams enqueued for deletion for lease table cleanup along with their scheduled time for deletion: {} ", - staleStreamDeletionMap.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, - entry -> entry.getValue().plus(waitPeriodToDeleteOldStreams)))); + if (!staleStreamDeletionMap.isEmpty()) { + log.warn( + "Streams enqueued for deletion for lease table cleanup along with their scheduled time for deletion: {} ", + staleStreamDeletionMap.entrySet().stream().collect(Collectors.toMap(Map.Entry::getKey, + entry -> entry.getValue().plus(waitPeriodToDeleteOldStreams)))); + } streamSyncWatch.reset().start();